jms - ActiveMQ connect to existing queue at an address/port -


i'm supposed send messages activemq queue named "ingestgenericjsonqueue" @ address 10.7.1.10 @ port 61616. can create activemqconnectionfactory object, how existing queue? far, i've managed find session.createqueue() function, i'm not sure if used create connection existing queue, or works create brand new queue. how can connect existing activemq queue name?

connectionfactory cfactory = new activemqconnectionfactory("tcp://10.7.1.10:61616"); connection connection = cfactory.createconnection(); connection.start(); session session = connection.createsession(false, session.auto_acknowledge);  destination queue = session.createqueue("ingestgenericjsonqueue");  system.out.println("queue connected");  messageproducer producer = session.createproducer(queue); textmessage m = session.createtextmessage(); m.settext(jsonstix.tostring());  producer.send(m);  system.out.println("done"); 

activemq creates queues , topics on demand if there no existing queue of name when create producer new queue created. if queue exists producer send queue.

you can use management tools jmx or web console explore running broker see queues exist already.


Comments