org.qbroker.jms

Class RMQMessenger

java.lang.Object

org.qbroker.net.RMQConnector

org.qbroker.jms.RMQMessenger

All Implemented Interfaces:

Connector

public class RMQMessenger
extends RMQConnector

RMQMessenger connects to a RabbitMQ server and initializes one of the operations, such as get and pub. It carries out the operation with support of JMS Messages.

There are two methods, get() and put(). The first method, get(), is used to get messages from a queue on the RabbitMQ server. The method of pub() is to publish messages with certain routing keys to the RabbitMQ server.

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.RMQConnector

isAuto, isDurable, isPassive, operation, password, RMQ_DIRECT, RMQ_FANOUT, RMQ_HEADERS, RMQ_TOPIC, username

Constructor Summary

Constructors

Constructor and Description
RMQMessenger(java.util.Map props) Creates new RMQMessenger

Method Summary

Modifier and Type	Method and Description
void	acknowledge(long[] state) acknowledges the RabbitMQ msgs only
static javax.jms.Message	convert(com.rabbitmq.client.QueueingConsumer.Delivery msg, byte[] body, boolean isText) converts a Delivery into a JMSEvent in the specific type and returns the new message where type 0 is for BytesMessage, 1 for TextMessage, 2 for MapMessage and 3 for ObjectMessage.
void	get(XQueue xq) retrieves messages from the RabbitMQ server and puts them to the XQ
static com.rabbitmq.client.AMQP.BasicProperties	getBasicProperties(javax.jms.Message msg)
java.lang.String	getOperation()
static boolean	isRMQMessage(javax.jms.Message msg)
void	pub(XQueue xq) It gets JMS messages from the XQueue and publishes them with certain routing keys to the RabbitMQ server.

Methods inherited from class org.qbroker.net.RMQConnector

ack, close, exchangeBind, exchangeDeclare, exchangeDelete, exchangeExists, exchangeUnbind, get, get, getConsumer, getDestination, getExchange, getExchangeType, getURI, getVirtualHost, isConnected, main, pub, pub, queueBind, queueDeclare, queueDelete, queueExists, queueUnbind, reconnect

Methods inherited from class java.lang.Object

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

Constructor Detail

RMQMessenger

public RMQMessenger(java.util.Map props)
             throws java.io.IOException

Creates new RMQMessenger

Throws:

java.io.IOException

Method Detail

get

public void get(XQueue xq)
         throws java.io.IOException,
                javax.jms.JMSException

retrieves messages from the RabbitMQ server and puts them to the XQ

Throws:

java.io.IOException

javax.jms.JMSException

pub

public void pub(XQueue xq)
         throws java.io.IOException,
                TimeoutException,
                javax.jms.JMSException

It gets JMS messages from the XQueue and publishes them with certain routing keys to the RabbitMQ server.

Throws:

java.io.IOException

TimeoutException

javax.jms.JMSException

convert

public static javax.jms.Message convert(com.rabbitmq.client.QueueingConsumer.Delivery msg,
                                        byte[] body,
                                        boolean isText)
                                 throws javax.jms.JMSException

converts a Delivery into a JMSEvent in the specific type and returns the new message where type 0 is for BytesMessage, 1 for TextMessage, 2 for MapMessage and 3 for ObjectMessage. In case of failure, it may just return null without exception.

Throws:

javax.jms.JMSException

getBasicProperties

public static com.rabbitmq.client.AMQP.BasicProperties getBasicProperties(javax.jms.Message msg)
                                                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isRMQMessage

public static boolean isRMQMessage(javax.jms.Message msg)
                            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

acknowledge

public void acknowledge(long[] state)
                 throws javax.jms.JMSException

acknowledges the RabbitMQ msgs only

Throws:

javax.jms.JMSException

getOperation

public java.lang.String getOperation()