import javax.jms.*; import org.hornetq.jms.client.HornetQJMSConnectionFactory; public class HornetQExample { public static void main(String[] args) throws JMSException { ConnectionFactory connectionFactory = new HornetQJMSConnectionFactory("tcp://localhost:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("exampleQueue"); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("Hello, HornetQ!"); producer.send(message); MessageConsumer consumer = session.createConsumer(destination); Message receivedMessage = consumer.receive(); System.out.println("Received message: " + ((TextMessage) receivedMessage).getText()); connection.close(); } }