Java message queue using MongoDB as a backend
Java
Switch branches/tags
Nothing to show
Latest commit 72cf50c Jul 23, 2013 Jonathan Gaillard Initial commit
Permalink
Failed to load latest commit information.
src Initial commit Jul 24, 2013
.gitignore Initial commit Jul 24, 2013
.travis.yml Initial commit Jul 24, 2013
README.md Initial commit Jul 24, 2013
pom.xml Initial commit Jul 24, 2013

README.md

#mongo-queue-java Build Status

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:

##Project Build

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

mvn clean install