<dependency> <groupId>org.hornetq</groupId> <artifactId>hornetq-jms-client</artifactId> <version>2.4.0.Final</version> </dependency> ConnectionFactory cf = new HornetQJMSConnectionFactory(false, new TransportConfiguration( NettyConnectorFactory.class.getName())); Destination destination = new HornetQTopic("topic.example"); Connection connection = cf.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer producer = session.createProducer(destination); MessageConsumer consumer = session.createConsumer(destination); TextMessage message = session.createTextMessage("Hello, HornetQ!"); producer.send(message); Message receivedMessage = consumer.receive(); if (receivedMessage instanceof TextMessage) { TextMessage textMessage = (TextMessage) receivedMessage; System.out.println("Received message: " + textMessage.getText()); }