messageQueue: Allow R to communicate with message queues

Share:

This package creates a simple way to interact with message queues regardless of the underlying provider of the queue (activeMQ or rabbitMQ). The idea is to provide this basic functionality such that R doesn't need to deal with the specifics of queues or their underlying implementation differences. Provides a simple way to PUT a text message on a queue and GET a text message from a queue.

Author
Matt MacGillivray
Date of publication
2013-04-22 21:23:25
Maintainer
Matt MacGillivray <matthew.macgillivray@cornell.edu>
License
LGPL (>= 2.0)
Version
0.5.1
URLs

View on R-Forge

Man pages

messageQueue.consumer.close
Close a consumer of a queue
messageQueue.consumer.getNextText
Retrieve the next available text message
messageQueue.factory.getConsumerFor
Connect to a queue for reading
messageQueue.factory.getProducerFor
Connect to a queue for writing
messageQueue-package
Allow R to put and get messages from message queues...
messageQueue.producer.close
Close a producer of a queue
messageQueue.producer.putText
Put a text message on a queue

Files in this package

messageQueue/DESCRIPTION
messageQueue/NAMESPACE
messageQueue/R
messageQueue/R/messageQueue.R
messageQueue/inst
messageQueue/inst/java
messageQueue/inst/java/log4j.properties
messageQueue/inst/java/messageQueue-0.3.0-full.jar
messageQueue/inst/javasrc
messageQueue/inst/javasrc/README.txt
messageQueue/inst/javasrc/messageQueue-0.3.0-sources.jar
messageQueue/inst/tests
messageQueue/inst/tests/test-consumer.R
messageQueue/inst/tests/test-producer.R
messageQueue/inst/tests/test-x-produce-consume.R
messageQueue/man
messageQueue/man/messageQueue-package.Rd
messageQueue/man/messageQueue.consumer.close.Rd
messageQueue/man/messageQueue.consumer.getNextText.Rd
messageQueue/man/messageQueue.factory.getConsumerFor.Rd
messageQueue/man/messageQueue.factory.getProducerFor.Rd
messageQueue/man/messageQueue.producer.close.Rd
messageQueue/man/messageQueue.producer.putText.Rd
messageQueue/tests
messageQueue/tests/dependencies.r
messageQueue/tests/test-all.R