JmsPlugin topic

Question

@绝望的八皮 你好，想跟你请教个问题：

我用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.

Answer 1

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

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

Answer 2

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