使用STOMP订阅ActiveMQ Artemis时遇到麻烦。队列已存在

Question

我在这里做错了什么？我试图使用Stomp在Artemis 2.13.0中测试一些东西，但是当我使用Python脚本的命令行实用程序时，我不能订阅队列，即使在我使用该实用程序将消息发布到一个地址之后也是如此。

另外，如果我给它一个新的队列名，它会创建它，但不会将我发布的消息拉到它。这让人困惑。我的实际Java应用程序的行为与此不同--它使用的是JMS

stomp -H 192.168.56.105 -P 61616 -U user -W password
> subscribe test3.topic::test.A.queue

Subscribing to 'test3.topic::test.A.queue' with acknowledge set to 'auto', id set to '1'
>
AMQ229019: Queue test.A.queue already exists on address test3.topic

这使得我认为Stomp试图在订阅时创建队列，但我在文档中没有看到如何管理这一点。http://jasonrbriggs.github.io/stomp.py/api.html

我也有一个Python脚本给我同样的问题。

import os
import time
import stomp

def connect_and_subscribe(conn):
    conn.connect('user', 'password', wait=True)
    conn.subscribe(destination='test3.topic::test.A.queue', id=1, ack='auto')

class MyListener(stomp.ConnectionListener):
    def __init__(self, conn):
        self.conn = conn

    def on_error(self, headers, message):
        print('received an error "%s"' % message)

    def on_message(self, headers, message):
        print('received a message "%s"' % message)
        """for x in range(10):
            print(x)
            time.sleep(1)
        print('processed message')"""

    def on_disconnected(self):
        print('disconnected')
        connect_and_subscribe(self.conn)

conn = stomp.Connection([('192.168.56.105', 61616)], heartbeats=(4000, 4000))
conn.set_listener('', MyListener(conn))
connect_and_subscribe(conn)
time.sleep(1000)
conn.disconnect()

Answer 1

我建议您尝试ActiveMQ Artemis的最新版本。自从2.13.0一年前发布以来，一些与STOMP相关的问题已经得到了修复，特别是ARTEMIS-2817，这看起来像您的用例。

我不清楚为什么要使用完全限定队列名(FQQN)，所以我倾向于认为这不是正确的方法，但无论如何，您遇到的问题应该在以后的版本中得到解决。如果您希望多个使用者在单个订阅中共享消息，那么使用FQQN将是一个不错的选择。

此外，如果希望使用主题/或队列/前缀来html" target="_blank">控制来自代理的路由语义，则应该按照文档中的描述适当地设置anycastprefix和multicastprefix。

这可能是巧合，但ARTEMIS-2817最初是由“Benjamin Lee Warrick”报告的，它与“Benw”（即你的名字）惊人地相似。