java多线程activemq,多线程JMS客户端ActiveMQ
我正在使用以下代碼創建多個JMS會話，以供多個使用者使用消息。我的問題是代碼以單線程方式運行。即使消息存在于隊列中，第二個線程也無法接收任何內容，而是繼續輪詢。同時，第一個線程完成對第一批的處理，然后返回并使用剩余的消息。這里的用法有什么問題嗎？
static {
try {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://172.16.143.99:61616");
connection = connectionFactory.createConnection();
connection.start();
} catch (JMSException e) {
LOGGER.error("Unable to initialise JMS Queue.", e);
}
}
public JMSClientReader(boolean isQueue, String name) throws QueueException {
init(isQueue,name);
}
@Override
public void init(boolean isQueue, String name) throws QueueException
{
// Create a Connection
try {
// Create a Session
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
if (isQueue) {
destination = new ActiveMQQueue(name);// session.createQueue("queue");
} else {
destination = new ActiveMQTopic(name);// session.createTopic("topic");
}
consumer = session.createConsumer(destination);
} catch (JMSException e) {
LOGGER.error("Unable to initialise JMS Queue.", e);
throw new QueueException(e);
}
}
public String readQueue() throws QueueException {
// connection.setExceptionListener(this);
// Wait for a message
String text = null;
Message message;
try {
message = consumer.receive(1000);
if(message==null)
return "done";
if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage) message;
text = textMessage.getText();
LOGGER.info("Received: " + text);
} else {
throw new JMSException("Invalid message found");
}
} catch (JMSException e) {
LOGGER.error("Unable to read message from Queue", e);
throw new QueueException(e);
}
LOGGER.info("Message read is " + text);
return text;
}
總結
以上是生活随笔為你收集整理的java多线程activemq,多线程JMS客户端ActiveMQ的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 空调室内机排水管在哪里？
- 下一篇： 腻子石膏完成墙面不平阴角不是直角怎么办？