import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import org.hornetq.jms.client.HornetQConnection;
import org.hornetq.jms.client.HornetQConnectionFactory;
class MyMessageListener implements MessageListener {
public void onMessage(Message message) {
System.out.println("Received message: " + message);
}
}
public class MessageListenerExample {
public static void main(String[] args) throws JMSException {
String serverUrl = "tcp://localhost:61616";
String username = "myUsername";
String password = "myPassword";
ConnectionFactory connectionFactory = new HornetQConnectionFactory(serverUrl);
Connection connection = connectionFactory.createConnection(username, password);
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("myQueue");
MessageListener messageListener = new MyMessageListener();
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(messageListener);
while (true) {
}
session.close();
connection.close();
}
}
- hornetq-commons.jar
- hornetq-core-client.jar
- hornetq-jms-client.jar
- jnp-client.jar
- jboss-logging.jar
- netty.jar
- concurrent.jar
- jboss-jms-api.jar
- jboss-logging-spi.jar
