#Turbine queue

Table of Contents

1. FAQs
2. License
3. Dependencies
4. Installation
5. Example

FAQs

What is turbineQueue? Turbine queue is messaging queue with high performance process

License

GPLv2

Dependencies

Turbine queue uses:

1. Apache log4j 1.4
2. Lombok library (for more details - http://www.projectlombok.org)
3. JUnit for test

Installation

<a name"installation" />

Open your command line:

git clone https://github.com/tgiachi/turbine-queue.git
cd turbine-queue/
mvn compile
mvn install

Add in your pom.xml

<dependency>
  <groupId>it.sistemisnc</groupId>
  <artifactId>turbinequeue</artifactId>
  <version>1.0-FINAL</version>
  <packaging>jar</packaging>
</dependency>

Example

<a name"example" />

//Initilize new queue
TurbineQueue turbineQueue = TurbineQueue.getInstance();

//Create new queue called "testqueue"
turbineQueue.addQueue("testqueue");

//Add class (implements IQueueListener) to Listeners
turbineQueue.addQueueListener("testqueue", this);

//Send test message
turbineQueue.sendMessage("testqueue", new Message(UUID.randomUUID().toString()));

[...]

@Override
public void onMessage(String queueName, Message message) {
    System.out.println("Message received from queueName  " + queueName + " type = " + message.getClass().getName() + " uid " + message.getGuid());
}

@Override
public void onReply(String queueName, Message message) {
    System.out.println("Message's reply " + message.getData());

}

@Override
public Message onDirectMessage(String queueName, Message message) {
   System.out.println("Receiving message with reply request from " + message.getSenderClass() );
   message.setData("Hello, I love, Won't you tell me your name?");

   return message;
}