ConnectionFactory factory = new HornetQJMSConnectionFactory(false, new TransportConfiguration(INVM_CONNECTOR_FACTORY)); Connection connection = factory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("myQueue"); MessageProducer producer = session.createProducer(destination); MessageConsumer consumer = session.createConsumer(destination); Message message = session.createTextMessage("Hello, World!"); producer.send(message); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { System.out.println("Received message: " + ((TextMessage) message).getText()); } });