tag:blogger.com,1999:blog-6449670593395906394.post6754799490312257050..comments2024-03-05T20:41:23.189-08:00Comments on Yasho Blog: RabbitMQ SSL connection Using RabbitMQ Event Adpter in WSO2 CEP- Part 2Yashohttp://www.blogger.com/profile/17683660632671919318noreply@blogger.comBlogger18125tag:blogger.com,1999:blog-6449670593395906394.post-57648514329557536032018-04-04T09:38:50.391-07:002018-04-04T09:38:50.391-07:00A very awesome blog post. We are really grateful f...A very awesome blog post. We are really grateful for your blog post. You will find a lot of approaches after visiting your post. <a href="https://www.sourcemiddleeast.com/companies/event-management-and-destinations-management-companies/party-planners-and-wedding-organisers/" rel="nofollow">event planning</a><br />Muhammad Hassanhttps://www.blogger.com/profile/04282277249728542966noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-37648132872285476662016-12-13T14:21:49.417-08:002016-12-13T14:21:49.417-08:00If you are going to write publisher, you can use s...If you are going to write publisher, you can use same procedure.Anonymousnoreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-39217001976847894122016-12-13T08:44:00.034-08:002016-12-13T08:44:00.034-08:00Can I use the same procedure to build a RabbitMQ P...Can I use the same procedure to build a RabbitMQ Publisher?Anonymoushttps://www.blogger.com/profile/07854127378413932533noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-62021702482755493012016-12-12T04:27:17.797-08:002016-12-12T04:27:17.797-08:00Anyone ?Anyone ?Magin Georgehttps://www.blogger.com/profile/07829069560500685689noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-47568533385918720712016-12-09T23:29:09.350-08:002016-12-09T23:29:09.350-08:00Enabled debug.....
[2016-12-09 23:20:33,206] INF...Enabled debug.....<br /><br />[2016-12-09 23:20:33,206] INFO - Successfully connected to RabbitMQ Broker rmq1 {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener}<br />[2016-12-09 23:20:33,209] DEBUG - Channel is not open. Creating a new channel for receiver rmq1 {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener}<br />[2016-12-09 23:20:33,218] DEBUG - Bind queue 'hello' to exchange 'collectd' with route key 'hello' {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener}<br />[2016-12-09 23:20:33,219] DEBUG - Start consuming queue 'hello' with consumer tag 'amq.ctag-XUByFcnT81b8NbCGawlNfA' for receiverrmq1 {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener}<br />[2016-12-09 23:20:33,220] DEBUG - Waiting for next delivery from queue for receiver {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener}<br />[2016-12-09 23:20:33,225] INFO - RabbitMQ connection closed for receiver rmq1 {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener}Magin Georgehttps://www.blogger.com/profile/07829069560500685689noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-64477925413523833042016-12-09T22:23:35.124-08:002016-12-09T22:23:35.124-08:00Thanks for your reply.
normal connection. below i...Thanks for your reply.<br /><br />normal connection. below is the log <br /><br />TID: [-1234] [] [2016-12-09 22:19:22,814] INFO {org.wso2.carbon.event.receiver.core.EventReceiverDeployer} - Event Receiver configuration successfully deployed and in active state: rmq1 <br />TID: [-1] [] [2016-12-09 22:19:22,819] INFO {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener} - Successfully connected to RabbitMQ Broker rmq1 <br />TID: [-1] [] [2016-12-09 22:19:22,839] INFO {org.wso2.carbon.extension.analytics.receiver.rabbitmq.internal.util.RabbitMQAdapterListener} - RabbitMQ connection closed for receiver rmq1 <br />the "connection closed" log entry comes as soon as i put a message in the queue. I don't know how to enable debug mode. Magin Georgehttps://www.blogger.com/profile/07829069560500685689noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-69436458055556285672016-12-09T21:43:09.070-08:002016-12-09T21:43:09.070-08:00Are you doing SSL connection or normal connection?...Are you doing SSL connection or normal connection? In rabbitmq receiver, it wont disconnect the connection until we shutdown the CEP. So could you please send the log when it disconnects? Anonymousnoreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-53323244734954453062016-12-09T15:07:23.922-08:002016-12-09T15:07:23.922-08:00Another observation. I can see that the cep consum...Another observation. I can see that the cep consumer for the queue when there is no message in the queue. but gets disconnected when a message comes to the queue. so cep is trying to processing the message and then it disconnects.Magin Georgehttps://www.blogger.com/profile/07829069560500685689noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-52950066310325152932016-12-09T14:30:36.021-08:002016-12-09T14:30:36.021-08:00Hi, Thanks for the blog ! I place the jar files as...Hi, Thanks for the blog ! I place the jar files as instructed and configured the Rabbitmq details. I see the exchange and queues are getting created. But the messages in the queue are not getting consumed. A in RMQ console the number of consumers is 0. The System logs dont give any error.<br /><br /><br /> 2016-12-09 14:21:38,119 Event Receiver configuration successfully deployed and in active state: CollectdRMQ <br />More<br /> 2016-12-09 14:21:38,118 Producer added to the junction. Stream:collectd:1.0.0 <br />More<br /> 2016-12-09 14:21:38,118 Connecting receiver CollectdRMQ <br />More<br /> 2016-12-09 14:21:38,118 Waiting to connect receiver CollectdRMQ <br />More<br /> 2016-12-09 14:21:38,114 Event receiver configuration saved to the filesystem :CollectdRMQ.xml<br /><br /><br />Can you please help here.<br /><br />RMQ Version 3.6.0<br />CEP 4.1.0<br /><br />Thanks,<br /><br />-MaginMagin Georgehttps://www.blogger.com/profile/07829069560500685689noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-85523282297144260102016-12-09T03:52:42.188-08:002016-12-09T03:52:42.188-08:00I have done rabbitmq receiver for the version of 3...I have done rabbitmq receiver for the version of 3.6.3. I am not sure about version 3.6.1. But now also i tested. If a message send to a rabbitmq queue, the receiver is accepting it.I am not sure about your problem. If you want code base of rabbitMQ receiver, see this link https://github.com/wso2-extensions/analytics-receiver-rabbitmqAnonymousnoreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-78614460348960312582016-12-09T03:39:57.648-08:002016-12-09T03:39:57.648-08:00I have create a receiver on wso2 CEP as you have w...I have create a receiver on wso2 CEP as you have written. I have created a Node Red publisher that sends MQTT data to RabbitMQ. I would send this data to wso2 CEP and so I built a receiver as you wrote. I' m seeing the Expception and I think that the problem could be in org.wso2.carbon.extension.analytics.receiver.rabbitmq-1.0.0.jar file, at file RabbitMQAdapterListener.class . I converted last file in RabbitMQAdapterListener.java, but for now I can' t understand how to solve this problem. Could be that RabbitMQ version (3.6.1) is old?Anonymoushttps://www.blogger.com/profile/07854127378413932533noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-22533656547919208102016-12-08T18:00:26.712-08:002016-12-08T18:00:26.712-08:00Are you creating receiver and publisher as your ow...Are you creating receiver and publisher as your own?Anonymousnoreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-6786582761205164652016-12-08T09:21:53.549-08:002016-12-08T09:21:53.549-08:00I have another problem: when I run the project on ...I have another problem: when I run the project on Management Console, I have this error: https://dl.dropboxusercontent.com/u/53209900/Exception.txt<br />I have made this configuration for receiver: https://dl.dropboxusercontent.com/u/53209900/TestReceiver.xml<br /><br />I have developed the project in Eclipse, as you can see here: https://dl.dropboxusercontent.com/u/53209900/Eclipse.png<br />and I added the Library Dependency (for maven) to the file TempDiffAnalytics/pom.xml as it is written here: https://www.rabbitmq.com/java-client.html .<br />I'm using RabbitMQ 3.6.1 and wso2 CEP 4.2.0 .<br />Can you help me, please?Anonymoushttps://www.blogger.com/profile/07854127378413932533noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-46730033706682050212016-12-08T03:14:28.202-08:002016-12-08T03:14:28.202-08:00This comment has been removed by the author.Anonymoushttps://www.blogger.com/profile/07854127378413932533noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-73803380514803604332016-12-07T08:31:38.860-08:002016-12-07T08:31:38.860-08:00Yes you can give a random name.Yes you can give a random name.Anonymousnoreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-75500187888920894922016-12-07T08:19:12.438-08:002016-12-07T08:19:12.438-08:00Ok, but what name? Can I do a random name?Ok, but what name? Can I do a random name?Anonymoushttps://www.blogger.com/profile/07854127378413932533noreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-61564158023651452682016-12-07T08:15:13.509-08:002016-12-07T08:15:13.509-08:00Here we mentioned exchange name as compulsory fiel...Here we mentioned exchange name as compulsory field. So you need to give a value to exchange name.Anonymousnoreply@blogger.comtag:blogger.com,1999:blog-6449670593395906394.post-51262239435860733932016-12-07T07:35:28.113-08:002016-12-07T07:35:28.113-08:00Hi, I'm trying to create a RabbitMQ Event Rece...Hi, I'm trying to create a RabbitMQ Event Receiver on wso2 CEP. I have placed the 2 .jar files in their own folders. But when I go on wso2 CEP console for creating an Event Receiver, I don' t understanding why I have to fill the "Exchange Name" field. I have to receive data from RabbitMQ and I think I mustn' t fill the "Exchanhe Name" field. Can you suggest me how to solve?Anonymoushttps://www.blogger.com/profile/07854127378413932533noreply@blogger.com