Package org.ow2.joram.mom.amqp

Class DirectExchange

java.lang.Object

org.ow2.joram.mom.amqp.IExchange

org.ow2.joram.mom.amqp.DirectExchange

All Implemented Interfaces:

Externalizable, Serializable, IExchangeMBean

public class DirectExchange
extends IExchange

The direct exchange type provides routing of messages to zero or more queues based on an exact match between the routing key of the message, and the binding key used to bind the queue to the exchange. This can be used to construct the classic point-to-point queue based messaging model, however, as with any of the defined exchange types, a message may end up in multiple queues when multiple binding keys match the message's routing key.
The direct exchange type works as follows:

• 1. A message queue is bound to the exchange using a binding key, K.
• 2. A publisher sends the exchange a message with the routing key R.
• 3. The message is passed to all message queues bound to the exchange with key K where K = R.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private Map<String,Set<String>>	bindings
static String	DEFAULT_NAME
static Logger	logger
private static long	serialVersionUID	define serialVersionUID for interoperability
static String	TYPE

Fields inherited from class org.ow2.joram.mom.amqp.IExchange

DEFAULT_EXCHANGE_NAME, durable, name, PREFIX_EXCHANGE

Constructor Summary

Constructors

Constructor	Description
DirectExchange()
DirectExchange(String name, boolean durable)

Method Summary

Modifier and Type	Method	Description
void	bind(String queueName, String routingKey, Map<String,Object> arguments)
void	doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
Set<String>	getBoundQueues()
String	getType()
boolean	isUnused()
void	readExternal(ObjectInput in)
void	removeQueueBindings(String queueName)
void	setArguments(Map<String,Object> arguments)
void	unbind(String queueName, String routingKey, Map<String,Object> arguments)
void	writeExternal(ObjectOutput out)

Methods inherited from class org.ow2.joram.mom.amqp.IExchange

checkPublication, createExchange, deleteExchange, getHandledMessageCount, getName, getPublishedMessageCount, isDurable, loadExchange, publish, publishToQueue, saveExchange

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

define serialVersionUID for interoperability

See Also:

Constant Field Values

logger

public static final Logger logger

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

Constant Field Values

TYPE

public static final String TYPE

See Also:

Constant Field Values

bindings

private Map<String,Set<String>> bindings

Constructor Detail

DirectExchange

public DirectExchange()

DirectExchange

public DirectExchange(String name,
                      boolean durable)

Method Detail

bind

public void bind(String queueName,
                 String routingKey,
                 Map<String,Object> arguments)

Specified by:

bind in class IExchange

unbind

public void unbind(String queueName,
                   String routingKey,
                   Map<String,Object> arguments)
            throws NotFoundException

Specified by:

unbind in class IExchange

Throws:

NotFoundException

doPublish

public void doPublish(String routingKey,
                      boolean mandatory,
                      boolean immediate,
                      AMQP.Basic.BasicProperties properties,
                      byte[] body,
                      int channelNumber,
                      short serverId,
                      long proxyId)
               throws NotFoundException,
                      NoConsumersException,
                      TransactionException

Specified by:

doPublish in class IExchange

Throws:

NotFoundException

NoConsumersException

TransactionException

setArguments

public void setArguments(Map<String,Object> arguments)

Specified by:

setArguments in class IExchange

isUnused

public boolean isUnused()

Specified by:

isUnused in class IExchange

getType

public String getType()

removeQueueBindings

public void removeQueueBindings(String queueName)

Specified by:

removeQueueBindings in class IExchange

getBoundQueues

public Set<String> getBoundQueues()

Specified by:

getBoundQueues in interface IExchangeMBean

Specified by:

getBoundQueues in class IExchange

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class IExchange

Parameters:

out -

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class IExchange

Parameters:

in -

Throws:

IOException

ClassNotFoundException