0

我使用 WSO2 MB 2.0.1，我尝试将教程中提供的 JMS Java 订阅者扩展为持久订阅者。然后停止 jms 客户端并向主题发送一些消息。但是当我启动 jms 客户端时，它没有收到消息。

有人可以让我知道如何创建持久订阅者。我的要求是当 jms 订阅者上线时接收消息。

我的代码：public void subscribe(String topicName) {

    Properties initialContextProperties = new Properties();
    initialContextProperties.put("java.naming.factory.initial",
            "org.wso2.andes.jndi.PropertiesFileInitialContextFactory");
    String connectionString = "amqp://admin:admin@clientID/carbon?brokerlist='tcp://localhost:5672'";
    initialContextProperties.put("connectionfactory.qpidConnectionfactory", connectionString);
    initialContextProperties.put("topic.myWarning", "myWarning");

    try {
        InitialContext initialContext = new InitialContext(initialContextProperties);
        TopicConnectionFactory topicConnectionFactory =
                (TopicConnectionFactory) initialContext.lookup("qpidConnectionfactory");
        TopicConnection topicConnection = topicConnectionFactory.createTopicConnection();
        //topicConnection.setClientID("clientID");
        topicConnection.start();
        TopicSession topicSession =topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);

        //Topic topic = topicSession.createTopic(topicName);
        Topic topic =(Topic) initialContext.lookup(topicName);
        TopicSubscriber topicSubscriber =
                topicSession.createDurableSubscriber(topic, "tom");
        TextMessage receivedMessage = (TextMessage)topicSubscriber.receive();
        System.out.println(receivedMessage);
       // topicSubscriber.setMessageListener(new JCOMessageListener(
        //        topicConnection, topicSession, topicSubscriber));

    } catch (NamingException e) {
        e.printStackTrace();
    } catch (JMSException e) {
        e.printStackTrace();
    }
}
4

2 回答 2

0

该链接可能对您有所帮助，

使用 WSO2 ESB 4.6.0 到 WSO2 Message Broker 2.1.0 制作持久主题订阅 http://abeykoon.blogspot.tw/2013/04/make-durable-topic-subscriptions-using.html

于 2013-07-31T08:54:20.447 回答
0

您的 JMS 客户端完全有效。

WSO2 MB 2.0.1 中的持久主题订阅存在错误。我们已经在 WSO2 MB 2.1.1 版本中修复了该问题，该版本将于今天起一个月内发布。

谢谢。

于 2013-01-11T04:20:45.543 回答