我正在尝试使用 JMS 实现在#Solace Appliance 上发送/接收消息。
我正在使用SolConnectionFactoryImpl
工厂来创建连接。一切看起来都很好,但是当我尝试将MessageListener
事件附加到 JMSMessageConsumer
时,Solace 的 API 会打印以下消息
前 26, 2016 12:40:28 PM com.solacesystems.jms.SolTopicSubscriber setMessageListener INFORMACIÓN:在 SolTopicSubscriber 中设置消息侦听器 null
在这里我创建MessageListener
:
MessageListener messageListenerConsumer = new MessageListener()
{
@Override
public void onMessage(Message arg0)
{
try {
textPane_1.setText(textPane_1.getText()+"puerquito consumido:"+((TextMessage)arg0).getText()+"\n");
textPane.setText(textPane.getText()+"puerquito consumido\n");
} catch(Exception er) {
textPane.setText(textPane.getText()+"Error al consumir el puerquito\n");
}
}
};
consumerParameter.setMessageListener(messageListenerConsumer);
在这里,我创建了消费者并附加了MessageListener
messageConsumer = session.createConsumer(destination);
messageConsumer.setMessageListener(consumerParameter.getMessageListener());
任何想法?
谢谢