uromahn / mongo-queue-java Goto Github PK

#mongo-queue-java

Java message queue using MongoDB as a backend Adheres to the 1.0.0 specification.

##Features

• Message selection and/or count via MongoDB query
• Distributes across machines via MongoDB
• Multi language support through the specification
• Message priority
• Delayed messages
• Running message timeout and redeliver
• Atomic acknowledge and send together
• Easy index creation based only on payload

##Simplest use

import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import gaillard.mongo.Queue;
import java.net.UnknownHostException;

public final class Main {

    public static void main(final String[] args) throws UnknownHostException {
        final Queue queue = new Queue(new MongoClient().getDB("testing").getCollection("messages"));
        queue.send(new BasicDBObject());
        final BasicDBObject message = queue.get(new BasicDBObject(), 60);
        queue.ack(message);
    }
}

##Jar

To add the library as a jar simply Build the project and use the mongo-queue-java-1.0.0.jar from the created target directory!

##Maven (TODO: Add project to Sonar OSS repo)

To add the library as a local, per-project dependency use Maven! Simply add a dependency on to your project's pom.xml file such as:

...
<dependency>
    <groupId>gaillard</groupId>
    <artifactId>mongo-queue-java</artifactId>
    <version>1.0.0</version>
</dependency>
...

##Documentation

Found in the source itself, take a look!

##Contact

Developers may be contacted at:

• Pull Requests
• Issues

##Project Build

Install and start mongodb. With a checkout of the code get Maven in your PATH and run:

mvn clean install