Properties props = new Properties(); props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.hornetq.jms.server.embedded.EmbeddedJMS"); props.setProperty(Context.PROVIDER_URL, "tcp://localhost:61616"); Context context = new InitialContext(props); ConnectionFactory factory = (ConnectionFactory) context.lookup("ConnectionFactory"); Connection connection = factory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Queue queue = session.createQueue("MyQueue"); MessageProducer producer = session.createProducer(queue); TextMessage message = session.createTextMessage("Hello, HornetQ!"); producer.send(message); MessageConsumer consumer = session.createConsumer(queue); Message receivedMessage = consumer.receive(); if (receivedMessage instanceof TextMessage) { TextMessage textMessage = (TextMessage) receivedMessage; String content = textMessage.getText(); System.out.println("Received message: " + content); } session.close(); connection.close();