qpid Producer和Consumer就同一个Session/Topic?
qpid Producer and Consumer on the same Session/Topic?
Brocker C++,客户端 java jms
向主题发送消息并在该主题上创建消费者后立即发送消息是否正确?
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
topic = (Destination) context.lookup("topicSend");
Destination tempTopic = (Destination) context.lookup("topicSend");
MessageProducer messageProducer = session.createProducer(topic);
messageProducer.send(messageToSend);
... 然后在同一会话和主题上创建一个消费者(topicSend 等于 tempTopic
MessageConsumer messageConsumer = session.createConsumer(tempTopic, MESSAGE_SELECTOR);
是的。那应该没问题。如果你完成了它,一定要关闭你的生产者。
我建议为生产者和消费者使用单独的 Session 以避免任何问题。
Brocker C++,客户端 java jms
向主题发送消息并在该主题上创建消费者后立即发送消息是否正确?
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
topic = (Destination) context.lookup("topicSend");
Destination tempTopic = (Destination) context.lookup("topicSend");
MessageProducer messageProducer = session.createProducer(topic);
messageProducer.send(messageToSend);
... 然后在同一会话和主题上创建一个消费者(topicSend 等于 tempTopic
MessageConsumer messageConsumer = session.createConsumer(tempTopic, MESSAGE_SELECTOR);
是的。那应该没问题。如果你完成了它,一定要关闭你的生产者。
我建议为生产者和消费者使用单独的 Session 以避免任何问题。