Package org.ow2.joram.mom.amqp

Class TopicExchange

java.lang.Object

org.ow2.joram.mom.amqp.IExchange

org.ow2.joram.mom.amqp.TopicExchange

All Implemented Interfaces:

Externalizable, Serializable, IExchangeMBean

public class TopicExchange
extends IExchange

The topic exchange type works as follows:

• 1. A message queue binds to the exchange using a routing pattern, P.
• 2. A publisher sends the exchange a message with the routing key R.
• 3. The message is passed to the message queue if R matches P.

The routing key used for a topic exchange MUST consist of zero or more words delimited by dots. Each word may contain the letters A-Z and a-z and digits 0-9.
The routing pattern follows the same rules as the routing key with the addition that * matches a single word, and # matches zero or more words. Thus the routing pattern *.stock.# matches the routing keys usd.stock and eur.stock.db but not stock.nasdaq.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	TopicExchange.KeyAndPattern	Class used to keep trace of the key which leads to the pattern.

Field Summary

Fields

Modifier and Type	Field	Description
private Map<TopicExchange.KeyAndPattern,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
TopicExchange()
TopicExchange(String name, boolean durable)

Method Summary

Modifier and Type	Method	Description
void	bind(String queueName, String routingKey, Map<String,Object> arguments)
private static Pattern	createPattern(String routingPattern)
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<TopicExchange.KeyAndPattern,Set<String>> bindings

Constructor Detail

TopicExchange

public TopicExchange()

TopicExchange

public TopicExchange(String name,
                     boolean durable)

Method Detail

createPattern

private static Pattern createPattern(String routingPattern)

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 NoConsumersException,
                      NotFoundException,
                      TransactionException

Specified by:

doPublish in class IExchange

Throws:

NoConsumersException

NotFoundException

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