org.qbroker.net

Class RMQConnector

java.lang.Object

org.qbroker.net.RMQConnector

All Implemented Interfaces:

Connector

Direct Known Subclasses:

RMQMessenger

public class RMQConnector
extends java.lang.Object
implements Connector

RMQConnector connects to an exchange on a RabbitMQ server and initializes the channel, the queue and the bindings for operations, such as check, get and pub.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isAuto
protected boolean	isDurable
protected boolean	isPassive
protected java.lang.String	operation
protected java.lang.String	password
static int	RMQ_DIRECT
static int	RMQ_FANOUT
static int	RMQ_HEADERS
static int	RMQ_TOPIC
protected java.lang.String	username

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	ack(long deliveryTag) acknowledges the RabbitMQ msgs only
void	close()
java.lang.String	exchangeBind(java.lang.String target, java.lang.String name, java.lang.String key)
java.lang.String	exchangeDeclare(java.lang.String name, java.lang.String type, boolean duable)
java.lang.String	exchangeDelete(java.lang.String name)
boolean	exchangeExists(java.lang.String name)
java.lang.String	exchangeUnbind(java.lang.String target, java.lang.String name, java.lang.String key)
byte[]	get(boolean autoAck, long timeout, java.util.Map<java.lang.String,java.lang.String> props) It waits for a message up to timeout in ms.
byte[]	get(long timeout, java.util.Map<java.lang.String,java.lang.String> props)
com.rabbitmq.client.QueueingConsumer	getConsumer(boolean ack)
java.lang.String	getDestination()
java.lang.String	getExchange()
int	getExchangeType()
java.lang.String	getURI()
java.lang.String	getVirtualHost()
boolean	isConnected()
static void	main(java.lang.String[] args)
void	pub(java.lang.String key, com.rabbitmq.client.AMQP.BasicProperties props, byte[] buff)
void	pub(java.lang.String key, com.rabbitmq.client.AMQP.BasicProperties props, java.lang.String msgStr)
java.lang.String	queueBind(java.lang.String queue, java.lang.String name, java.lang.String key)
java.lang.String	queueDeclare(java.lang.String name, boolean durable)
java.lang.String	queueDelete(java.lang.String name)
boolean	queueExists(java.lang.String name)
java.lang.String	queueUnbind(java.lang.String queue, java.lang.String name, java.lang.String key)
java.lang.String	reconnect() It reconnects and returns null or error message upon failure

Methods inherited from class java.lang.Object

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

Field Detail

username

protected java.lang.String username

password

protected java.lang.String password

operation

protected java.lang.String operation

isDurable

protected boolean isDurable

isAuto

protected boolean isAuto

isPassive

protected boolean isPassive

RMQ_DIRECT

public static final int RMQ_DIRECT

See Also:

Constant Field Values

RMQ_FANOUT

public static final int RMQ_FANOUT

See Also:

Constant Field Values

RMQ_TOPIC

public static final int RMQ_TOPIC

See Also:

Constant Field Values

RMQ_HEADERS

public static final int RMQ_HEADERS

See Also:

Constant Field Values

Constructor Detail

RMQConnector

public RMQConnector(java.util.Map props)

Creates new RMQConnector

Method Detail

get

public byte[] get(long timeout,
                  java.util.Map<java.lang.String,java.lang.String> props)
           throws java.io.IOException

Throws:

java.io.IOException

get

public byte[] get(boolean autoAck,
                  long timeout,
                  java.util.Map<java.lang.String,java.lang.String> props)
           throws java.io.IOException

It waits for a message up to timeout in ms. Upon received a message, it returns byte array of the message body and fills in the property map with RabbitMQ properties. If timeout is 0 or less, there is no wait. If there is no message received, it returns null.

Throws:

java.io.IOException

pub

public void pub(java.lang.String key,
                com.rabbitmq.client.AMQP.BasicProperties props,
                byte[] buff)
         throws java.io.IOException

Throws:

java.io.IOException

pub

public void pub(java.lang.String key,
                com.rabbitmq.client.AMQP.BasicProperties props,
                java.lang.String msgStr)
         throws java.io.IOException

Throws:

java.io.IOException

exchangeExists

public boolean exchangeExists(java.lang.String name)

queueExists

public boolean queueExists(java.lang.String name)

exchangeDeclare

public java.lang.String exchangeDeclare(java.lang.String name,
                                        java.lang.String type,
                                        boolean duable)

exchangeDelete

public java.lang.String exchangeDelete(java.lang.String name)

exchangeBind

public java.lang.String exchangeBind(java.lang.String target,
                                     java.lang.String name,
                                     java.lang.String key)

exchangeUnbind

public java.lang.String exchangeUnbind(java.lang.String target,
                                       java.lang.String name,
                                       java.lang.String key)

queueBind

public java.lang.String queueBind(java.lang.String queue,
                                  java.lang.String name,
                                  java.lang.String key)

queueUnbind

public java.lang.String queueUnbind(java.lang.String queue,
                                    java.lang.String name,
                                    java.lang.String key)

queueDeclare

public java.lang.String queueDeclare(java.lang.String name,
                                     boolean durable)

queueDelete

public java.lang.String queueDelete(java.lang.String name)

getConsumer

public com.rabbitmq.client.QueueingConsumer getConsumer(boolean ack)
                                                 throws java.io.IOException

Throws:

java.io.IOException

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

reconnect

public java.lang.String reconnect()

It reconnects and returns null or error message upon failure

Specified by:

reconnect in interface Connector

ack

public void ack(long deliveryTag)
         throws java.io.IOException

acknowledges the RabbitMQ msgs only

Throws:

java.io.IOException

getVirtualHost

public java.lang.String getVirtualHost()

getExchange

public java.lang.String getExchange()

getDestination

public java.lang.String getDestination()

getExchangeType

public int getExchangeType()

close

public void close()

Specified by:

close in interface Connector

main

public static void main(java.lang.String[] args)