Приложение Siddhi Не удается получить сообщение в ampq-потребителе от процессора Wso2 Stream - PullRequest
Новая
       10

Приложение Siddhi Не удается получить сообщение в ampq-потребителе от процессора Wso2 Stream

0 голосов
/ 22 февраля 2019

Я пытаюсь опубликовать события из приложения siddhi в брокере rabbitmq, чтобы их мог получить потребитель.Я использую java-скрипт и среда выполнения является узлом:

receive.js 

#!/usr/bin/env node

  var amqp = require('amqplib/callback_api');
    amqp.connect('amqp://localhost', function(err, conn) {
  conn.createChannel(function(err, ch) {
    var q = 'hello';

    ch.assertQueue(q, {durable: false});
    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
    ch.consume(q, function(msg) {
      console.log(msg);
    }, {noAck: true});
  });
})

seddhi app: 

@App:name('TestExecutionPlan') 
define stream FooStream (msg string); 
@info(name = 'query1')
@sink(type ='rabbitmq',
uri = 'amqp://localhost',
exchange.type = 'direct',
exchange.name='amq.direct',
exchange.durable.enabled="false",
queue.name='hello',
routing.key= 'direct',
@map(type='text'))
Define stream BarStream(msg string);
from FooStream select msg insert into BarStream;

Когда я моделирую событие в редакторе WSo2, яне получите никаких ошибок, однако никаких признаков сообщения нигде не видно.ни в очереди, ни в консоли.Может кто-нибудь, пожалуйста, помогите

...