import javax.jms.*;
public class HornetQSender {
public static void main(String[] args) throws JMSException {
ConnectionFactory factory = new org.hornetq.jms.client.HornetQJMSConnectionFactory("tcp://localhost:5445");
Connection connection = factory.createConnection();
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);
connection.close();
}
}
<dependency>
<groupId>org.hornetq</groupId>
<artifactId>hornetq-jms-client</artifactId>
<version>2.4.7.Final</version>
</dependency>
