import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.hornetq.jms.client.HornetQConnectionFactory;
public class JmsClient {
public static void main(String[] args) throws Exception {
ConnectionFactory factory = new HornetQConnectionFactory();
Connection connection = factory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("exampleQueue");
MessageProducer producer = session.createProducer(queue);
TextMessage message = session.createTextMessage("Hello, HornetQ!");
producer.send(message);
session.close();
connection.close();
}
}
