Map<String, Object> connectionParams = new HashMap<>(); connectionParams.put("host", "localhost"); connectionParams.put("port", 5445); connectionParams.put("username", "admin"); connectionParams.put("password", "password"); InitialContext initialContext = new InitialContext(); ConnectionFactory connectionFactory = (ConnectionFactory) initialContext.lookup("java:/ConnectionFactory"); Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = (Destination) initialContext.lookup("queue/MyQueue"); MessageProducer producer = session.createProducer(destination); MessageConsumer consumer = session.createConsumer(destination); TextMessage message = session.createTextMessage("Hello, HornetQ!"); producer.send(message); TextMessage receivedMessage = (TextMessage) consumer.receive(); System.out.println("Received message: " + receivedMessage.getText()); session.close(); connection.close();