Posts

Showing posts with the label qpid

Using Apache Qpid with WSO2 CEP

Using Apache Qpid with WSO2 CEP Though WSO2 CEP 2.x.x can work with Qpid, it does not have samples that demonstrates this, where  CEP only have samples for ActiveMQ. Here Im providing steps to configure, and run some samples using Apache Qpid. First step is downloading and running Apache Qpid. You can download Qpid from the project web site. Note, I have used Qpid java 0.18 for these samples, you can download that from here. Next, unzip and start the broker. Now to configure WSO2 CEP with Qpid JMS broker, follow the steps provided at Configuring JMS-Qpid Broker. Test publishing and subscribing to JMS Map messages Edit the jms-twitter-stockquote-analyser.xml provided at /samples/cep-samples/conf/buckets directory by changing the input and output broker names as,  <bucket name="TwitterAndStockQuoteAnalyzer" >      ...      <input topic="AllStockQuotes" brokerName="qpidJmsBroker">      ...     ...