ESB WSO2 - Подключите потребителя к CloudAmqp с RabbitMQ - PullRequest
Новая
       11

ESB WSO2 - Подключите потребителя к CloudAmqp с RabbitMQ

0 голосов
/ 28 августа 2018

Я пытаюсь подключить ESB WSO2 к очереди из CloudAMQP с RabbitMQ, используя хранилища сообщений и обработчик сообщений.

Я не знаю, хороший ли это путь. Поэтому я создал хранилища сообщений, чтобы создать соединение на моем экземпляре CloudAMQP, например: 

<?xml version="1.0" encoding="UTF-8"?>
<messageStore class="org.apache.synapse.message.store.impl.rabbitmq.RabbitMQStore" name="AmqpConnection" xmlns="http://ws.apache.org/ns/synapse">
    <parameter name="store.rabbitmq.host.name">flamingo.rmq.cloudamqp.com</parameter>
    <parameter name="store.producer.guaranteed.delivery.enable">false</parameter>
    <parameter name="store.rabbitmq.host.port">5672</parameter>
    <parameter name="store.rabbitmq.route.key">event.lifecycle</parameter>
    <parameter name="store.rabbitmq.username">XXXXX</parameter>
    <parameter name="store.rabbitmq.virtual.host">XXXXX</parameter>
    <parameter name="rabbitmq.connection.ssl.enabled">false</parameter>
    <parameter name="store.rabbitmq.exchange.name">opencell.event</parameter>
    <parameter name="store.rabbitmq.queue.name">event.lifecycle</parameter>
    <parameter name="store.rabbitmq.password">XXXXX</parameter>
</messageStore>

Соединение было хорошо создано:

enter image description here

И я создал MessageProcessor, чтобы подключить его к моей очереди: 

<?xml version="1.0" encoding="UTF-8"?>
<messageProcessor class="org.apache.synapse.message.processor.impl.sampler.SamplingProcessor" messageStore="AmqpConnection" name="AmqpProcessor" xmlns="http://ws.apache.org/ns/synapse">
    <parameter name="cronExpression">0 */15* ? * *</parameter>
    <parameter name="sequence">AmqpTest</parameter>
    <parameter name="interval">1000</parameter>
    <parameter name="is.active">true</parameter>
    <parameter name="concurrency">1</parameter>
</messageProcessor>

Я ласкаю это выражение cron: 0 / 15 ? * * каждые 15 минут соединение с очередью будет перезагружаться (я думаю, что это так)

Но у меня не было пользователя, подключенного к моей очереди с этим процессором. Знаете ли вы, если я что-то забыл? Или я должен создать файл служб прокси? Спасибо за ваш ответ.

...