org.qbroker.jms

Class RiakMessenger

java.lang.Object

org.qbroker.net.RiakConnector

org.qbroker.jms.RiakMessenger

public class RiakMessenger
extends RiakConnector

RiakMessenger connects to a Riak database specified by URI and initializes the operations of fetch, store and download with JMS Messages on various data buckets.

This is NOT MT-Safe. Therefore, you need to use multiple instances to achieve your MT goal.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.net.RiakConnector

ACTION_COUNT, ACTION_DELETE, ACTION_FETCH, ACTION_LIST, ACTION_STORE, hostname, isConnected, password, port, riakClient, uri, username

Constructor Summary

Constructors

Constructor and Description
RiakMessenger(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	download(XQueue xq) It listens to an XQueue for incoming JMS messages and extracts the bucket name and the key name from each message.
void	fetch(XQueue xq) It fetches content with the default key from the Riak service and loads content into a message before sending it to the XQ.
java.lang.String	getOperation()
void	store(XQueue xq) It gets a JMS Message from the XQueue and stores its content into a bucket with the given key.

Methods inherited from class org.qbroker.net.RiakConnector

close, delete, fetch, fetchBucket, getURI, isConnected, list, main, reconnect, store, store

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RiakMessenger

public RiakMessenger(java.util.Map props)

Method Detail

fetch

public void fetch(XQueue xq)
           throws NonSQLException,
                  javax.jms.JMSException

It fetches content with the default key from the Riak service and loads content into a message before sending it to the XQ.

Throws:

NonSQLException

javax.jms.JMSException

store

public void store(XQueue xq)
           throws TimeoutException,
                  NonSQLException,
                  javax.jms.JMSException

It gets a JMS Message from the XQueue and stores its content into a bucket with the given key.

It always tries to retrieve the bucket name from the field specified by BucketField and the key name from the field specified by the KeyField. If the message does not contain the bucket or key, the method will use the default values.

If the XQueue has enabled the EXTERNAL_XA bit, it will also acknowledge the messages. This method is MT-Safe.

Throws:

TimeoutException

NonSQLException

javax.jms.JMSException

download

public void download(XQueue xq)
              throws TimeoutException,
                     NonSQLException,
                     javax.jms.JMSException

It listens to an XQueue for incoming JMS messages and extracts the bucket name and the key name from each message. Then it downloads the content from the Riak server and loads the content to the message body.

If the MaxIdleTime is set to none-zero, it will monitor the idle time and will throw TimeoutException once the idle time exceeds MaxIdleTime. it is up to the caller to handle this exception.

The original message will not be modified. If the XQueue has enabled the EXTERNAL_XA bit, it will also acknowledge the messages also.

Throws:

TimeoutException

NonSQLException

javax.jms.JMSException

getOperation

public java.lang.String getOperation()