недопустимый uri: stomp: //0.0.0.0: 61613 [недопустимые посредники: объект 'NoneType' не имеет атрибута 'groupdict'] - PullRequest
Новая
       21

недопустимый uri: stomp: //0.0.0.0: 61613 [недопустимые посредники: объект 'NoneType' не имеет атрибута 'groupdict']

0 голосов
/ 25 сентября 2019

Я пытаюсь подключиться к своему локальному 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&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;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?

1 Ответ

1 голос
/ 25 сентября 2019

Глядя на клиентскую документацию STOMPest (?), Становится очевидным, что вы используете неправильный URI.Схема URI stompm неверна в соответствии с примерами, которые задокументированы здесь .Клиентская документация, которую я смог найти, будет указывать, что вы хотите использовать схему URI 'tcp' или 'ssl' в зависимости от того, что вы хотите использовать в качестве транспорта.

...