JmsPlugin topic

Jacky_D_H 发布于 2015/03/13 15:32
阅读 115
收藏 1

@绝望的八皮 你好,想跟你请教个问题:

我用activemq做broker, 使用jfinal-ext JmsPlugin sendQueue可以正常工作,能够接收到queue message.

但使用sendTopic时却收到不topic message.

    @Test
    public void send() throws InterruptedException {
        JmsPlugin jmsPlugin = new JmsPlugin("jms.properties");
        jmsPlugin.start();
        //JmsKit.sendQueue("q1", new M(), "a");
        JmsKit.sendTopic("t1", new M(), "c");
        TimeUnit.SECONDS.sleep(60);
    }

是这样使用的吗?

BTW, 我看到有人这样说:

use createDurableSubscriber() method instead of createConsumer() for transmitting message via topic.

Thanks.


加载中
0
绝望的八皮
绝望的八皮
这个东西很久没有用过了,不知道是不是版本问题?你用的activemq是我依赖那个版本么?我以前是试用过可以的或者你用那个推荐方法试一试能行?
0
Jacky_D_H
Jacky_D_H

引用来自“绝望的八皮”的评论

这个东西很久没有用过了,不知道是不是版本问题?你用的activemq是我依赖那个版本么?我以前是试用过可以的或者你用那个推荐方法试一试能行?

使用的activemq version 是 5.11.1

查了api,把TopicListener.java里initListener() session.createTopic改为

destination = new ActiveMQTopic(topicName);
就可以了。

返回顶部
顶部