Hi All, I have planned to develop RabbitMQ Input Adapter (Receiver) for CEP. RabbitMQ task is getting the messages and forward it to the receiver. A "Consumer (C)" is a program that mostly waits to receive messages. Queue is the one which stores messages for a sometime. Exchange on one side it receives messages from producers and the other side it pushes them to queues. The exchange must know exactly what to do with a message it receives. As I am going to do Input Adapter I have to focus on Consumer part. RabbitMQ receiver have to connect to broker and listen for messages from particular queue and exchange. I planned to use Axis2 transport as CEP is integrated with Axis2 Transport. I planned to use binary message builder and after that read the message and create the internal event format.
Your comments and suggestions are highly appreciated. Thanks. Best Regards, Yashothara.S Software Engineer WSO2
_______________________________________________ Architecture mailing list [email protected] https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture
