Package org.ow2.joram.mom.amqp

Class IExchange

java.lang.Object

org.ow2.joram.mom.amqp.IExchange

All Implemented Interfaces:

Externalizable, Serializable, IExchangeMBean

Direct Known Subclasses:

DirectExchange, FanoutExchange, HeadersExchange, TopicExchange

public abstract class IExchange
extends Object
implements IExchangeMBean, Externalizable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_EXCHANGE_NAME
protected boolean	durable
private long	handledMessageCount
static Logger	logger
protected String	name
static String	PREFIX_EXCHANGE
private boolean	published
private long	publishedMessageCount
private String	saveName
private static long	serialVersionUID	define serialVersionUID for interoperability

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
abstract void	bind(String queueName, String routingKey, Map<String,Object> arguments)
protected void	checkPublication(boolean mandatory)
protected void	createExchange()
protected void	deleteExchange()
abstract void	doPublish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
abstract Set<String>	getBoundQueues()
long	getHandledMessageCount()
String	getName()
long	getPublishedMessageCount()
boolean	isDurable()
abstract boolean	isUnused()
static IExchange	loadExchange(String name)
void	publish(String routingKey, boolean mandatory, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
protected void	publishToQueue(String queueName, String routingKey, boolean immediate, AMQP.Basic.BasicProperties properties, byte[] body, int channelNumber, short serverId, long proxyId)
void	readExternal(ObjectInput in)
abstract void	removeQueueBindings(String queueName)
protected void	saveExchange()
abstract void	setArguments(Map<String,Object> arguments)
abstract void	unbind(String queueName, String routingKey, Map<String,Object> arguments)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.ow2.joram.mom.amqp.IExchangeMBean

getType

Field Detail

logger

public static final Logger logger

serialVersionUID

private static final long serialVersionUID

define serialVersionUID for interoperability

See Also:

Constant Field Values

DEFAULT_EXCHANGE_NAME

public static final String DEFAULT_EXCHANGE_NAME

See Also:

Constant Field Values

PREFIX_EXCHANGE

public static final String PREFIX_EXCHANGE

See Also:

Constant Field Values

saveName

private String saveName

name

protected String name

durable

protected boolean durable

handledMessageCount

private long handledMessageCount

publishedMessageCount

private long publishedMessageCount

published

private boolean published

Constructor Detail

IExchange

public IExchange()

IExchange

public IExchange(String name,
                 boolean durable)

Method Detail

publishToQueue

protected void publishToQueue(String queueName,
                              String routingKey,
                              boolean immediate,
                              AMQP.Basic.BasicProperties properties,
                              byte[] body,
                              int channelNumber,
                              short serverId,
                              long proxyId)
                       throws NoConsumersException,
                              TransactionException

Throws:

NoConsumersException

TransactionException

checkPublication

protected void checkPublication(boolean mandatory)
                         throws NotFoundException

Throws:

NotFoundException

publish

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

Throws:

NoConsumersException

NotFoundException

TransactionException

doPublish

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

Throws:

NoConsumersException

NotFoundException

TransactionException

bind

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

unbind

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

Throws:

NotFoundException

isUnused

public abstract boolean isUnused()

setArguments

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

removeQueueBindings

public abstract void removeQueueBindings(String queueName)
                                  throws TransactionException

Throws:

TransactionException

getBoundQueues

public abstract Set<String> getBoundQueues()

Specified by:

getBoundQueues in interface IExchangeMBean

getName

public String getName()

Specified by:

getName in interface IExchangeMBean

getHandledMessageCount

public long getHandledMessageCount()

Specified by:

getHandledMessageCount in interface IExchangeMBean

getPublishedMessageCount

public long getPublishedMessageCount()

Specified by:

getPublishedMessageCount in interface IExchangeMBean

isDurable

public boolean isDurable()

Specified by:

isDurable in interface IExchangeMBean

loadExchange

public static IExchange loadExchange(String name)
                              throws IOException,
                                     ClassNotFoundException,
                                     TransactionException

Throws:

IOException

ClassNotFoundException

TransactionException

createExchange

protected final void createExchange()

saveExchange

protected final void saveExchange()

deleteExchange

protected final void deleteExchange()
                             throws AccessRefusedException

Throws:

AccessRefusedException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Parameters:

out -

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Parameters:

in -

Throws:

IOException

ClassNotFoundException