2
回答
JmsPlugin topic
科大讯飞通用文字识别100000次/天免费使用。立即申请   

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

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


举报
Jacky_D_H
发帖于3年前 2回/114阅
顶部