#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
importcom.mongodb.BasicDBObject;
importcom.mongodb.MongoClient;
importgaillard.mongo.Queue;
importjava.net.UnknownHostException;
publicfinalclassMain {
publicstaticvoidmain(finalString[] args) throwsUnknownHostException {
finalQueuequeue = newQueue(newMongoClient().getDB("testing").getCollection("messages"));
queue.send(newBasicDBObject());
finalBasicDBObjectmessage = queue.get(newBasicDBObject(), 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