Accepting data from WSo2 Stream processor

[Brazili sayev]

Hi ,

So i am new into this business, but am trying to send messages from WSo2 stream processor using (Siddhi app) .

I really don't know what i am doing am neither experienced with rabbitmq nor WSo2 . Here is what i wrote: 

@sink(type ='rabbitmq', uri = 'amqp://localhost',queue.name='hello',exchange.name='direct',routing_key='hello', @map(type='json'))

Following this guide : https://wso2-extensions.github.io/siddhi-io-rabbitmq/api/1.1.0/#rabbitmq-sink

But i can't receive the message and also i can't see any messages in the Receivers queue .

Can someone help please.

 

[Mohanadarshan Vivekanandalingam]

Hi Brazili,

It would be good if you can raise these queries in WSO2 dev mail thread (or siddhi user group). https://wso2.com/community

Regarding your query. I have just now tested WSO2 Stream Processor with RabbitMQ and it works fine. For example, please check below Siddhi application. 

I have tested this siddhi application through WSO2 Stream Processor editor by simulating some events to BarStream . As shown in the query, I am sending some events to rabbitmq and again consuming them back and logging them. 

Have you got any errors in WSO2 Stream Processor when sending events to RabbitMQ server?

@App:name('TestExecutionPlan')


define stream FooStream (symbol string, price float, volume long);


@sink(type='log')

@source(type='rabbitmq', uri = 'amqp://guest:guest@localhost:5672', queue.name='hello', routing_key='hello',
exchange.name = 'direct',
exchange.autodelete.enabled = 'true',
@map(type='json'))
Define stream BarStream1 (symbol string, price float, volume long);


@info(name = 'query1')

@sink(type ='rabbitmq', uri = 'amqp://guest:guest@localhost:5672', queue.name='hello', routing_key='hello',
exchange.name = 'direct', @map(type='json'))
define stream BarStream (symbol string, price float, volume long);
from FooStream
select symbol, price, volume
insert into BarStream;

Thanks,

Mohan