Posts

Showing posts with the label apache

Using Apache Accumulo as the backing store for Apache Gora a tutorial

Using Apache Accumulo as the backing store for Apache Gora a tutorial Apache Gora (http://gora.apache.org/) provides an abstraction layer to work with various data storage engines. In this tutorial, well see how to use Gora with Apache Accumulo as the storage engine. I like to start projects with the Maven `pom.xml` file. So here is mine. Its important to use Accumulo 1.4.3 instead of the newly released 1.5.0 because of an API incompatibility. Otherwise, the `pom.xml` file is straightforward. <project ...> <modelVersion>4.0.0</modelVersion> <groupId>com.affy</groupId> <artifactId>pojos-in-accumulo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>POJOs in Accumulo</name> <url>http://affy.com</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <!-- Dependency Versions --> <accumulo.version>1.4.3...

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">      ...     ...