public class MessageReceiver {
// URL of the JMS server
private static String url = "tcp://atuleusbduv012.aemud.com:61616";
// default broker URL is : tcp://localhost:61616"
// Name of the queue we will receive messages from
private static String subject = "activemq.test.incoming.master";
// Queue Name.You can create any/many queue names as per your requirement.
public static void main(String[] args) throws JMSException, InterruptedException {
// Getting JMS connection from the server
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("agile","123456789",url);
//ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start();
// Creating session for sending messages
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
System.out.println("session :: "+session.toString());
// Getting the queue 'amd.tmpesb.sapphire.incoming.master'
Destination destination = session.createQueue(subject);
System.out.println("destination :: "+destination.toString());
// MessageConsumer is used for receiving (consuming) messages
MessageConsumer consumer = session.createConsumer(destination);
System.out.println("consumer :: "+consumer.toString());
// Here we receive the message.
Message message = consumer.receive();
System.out.println("message :: "+message.toString());
// We will be using TestMessage in our example. MessageProducer sent us a TextMessage
// so we must cast to it to get access to its .getText() method.
if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage) message;
System.out.println("Received message '" + textMessage.getText() + "'");
}
connection.close();
}
}
Выше кода не читает сообщения из очереди, когда я отладил Java-класс, я обнаружил, что «выполнение остановлено на consumer.receive(); методе, то есть он постоянно пытается прочитать сообщения, но не может прочитать.
Пожалуйста, дайте мне знать, что мне не хватает в MessageReceiver классе
Также для получения более подробной информации об отправке / записи сообщения в вышеуказанную очередь.
Мы используем класс ниже для отправки сообщений в очередь activemq.test.incoming.master и успешно отправляем сообщения
public class MessageSender {
//URL of the JMS server. DEFAULT_BROKER_URL will just mean that JMS server is on localhost
private static String url = "tcp://atuleusbduv012.aemud.com:61616";
//private static String url = "tcp://localhost:61616";
// default broker URL is : tcp://localhost:61616"
private static String subject = "activemq.test.incoming.master";
// Queue Name.You can create any/many queue names as per your requirement.
public static void main(String[] args) throws JMSException {
// Getting JMS connection from the server and starting it
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("agile","123456789",url);
//ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start();
//Creating a non transactional session to send/receive JMS message.
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
//Destination represents here our queue 'JCG_QUEUE' on the JMS server.
//The queue will be created automatically on the server.
Destination destination = session.createQueue(subject);
// MessageProducer is used for sending messages to the queue.
MessageProducer producer = session.createProducer(destination);
// We will send a small text message saying 'Hello World!!!'
TextMessage message = session.createTextMessage("Hello !!! Welcome to the world of ActiveMQ.");
// Here we are sending our message!
producer.send(message);
System.out.println("JCG printing@@ '" + message.getText() + "'");
connection.close();
}
}
Прошу сообщить мне, что мне не хватает в вышеприведенном MessageReceiver классе, из-за которого он не читает сообщения из очереди activemq.test.incoming.master.