Package org.ow2.joram.mom.amqp

Class FanoutExchange

java.lang.Object

org.ow2.joram.mom.amqp.IExchange

org.ow2.joram.mom.amqp.FanoutExchange

All Implemented Interfaces:

Externalizable, Serializable, IExchangeMBean

public class FanoutExchange
extends IExchange

The fanout exchange type works as follows:

• 1. A message queue binds to the exchange with no arguments.
• 2. A publisher sends the exchange a message.
• 3. The message is passed to the message queue unconditionally.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private Set<String>	boundQueues
static String	DEFAULT_NAME
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, logger, name, PREFIX_EXCHANGE

Constructor Summary

Constructors

Constructor	Description
FanoutExchange()
FanoutExchange(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

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

Constant Field Values

TYPE

public static final String TYPE

See Also:

Constant Field Values

boundQueues

private Set<String> boundQueues

Constructor Detail

FanoutExchange

public FanoutExchange()

FanoutExchange

public FanoutExchange(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 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