我正在尝试连接到本地ActiveMQ。在尝试连接时,我收到以下消息:
无效的uri:stomp://0.0.0.0:61613 [无效的代理:'NoneType'对象没有属性'groupdict']
我的[[activemq.xml具有以下输入项
<transportConnectors>
<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
这是我的代码
def copy_activemq_to_s3(): """ :param environment_config: :param entity_config: :param entity_name: :return: """ uri = "stomp://0.0.0.0:61613" user_name = "system" password = "manager" queue = "my_queue" connection = stormpest_conn(uri, user_name, password) # write_message(connection, queue) read_message(connection, queue) def stormpest_conn(uri, user_name, password): config = StompConfig( uri=uri, login=user_name, passcode=password, sslContext=sslContext ) client = Stomp(config) client.connect(connectTimeout=10000, connectedTimeout=10000) return client
现在我不知道是什么导致它连接到ActiveMQ?