Package org.ow2.joram.mom.amqp

Class Proxy

java.lang.Object

org.ow2.joram.mom.amqp.Proxy

All Implemented Interfaces:

DeliveryListener, ProxyMBean

public class Proxy
extends Object
implements DeliveryListener, ProxyMBean

Handles the AMQP frames received by the AMQPConnectionListener.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	Proxy.NetServerIn

Field Summary

Fields

Modifier and Type	Field	Description
private Map<Integer,ChannelContext>	channelContexts
private Set<QueueShell>	exclusiveQueues
private static Logger	logger
private ProxyName	name
private Proxy.NetServerIn	netServerIn
static String	PREFIX_PX
private static long	proxyId
private Queue	queueIn
private Queue	queueOut
private Transaction	transaction

Constructor Summary

Constructors

Constructor	Description
Proxy(Queue queueIn, Queue queueOut)

Method Summary

Modifier and Type	Method	Description
void	basicAck(AMQP.Basic.Ack ack)
void	basicCancel(String consumerTag, int channelNumber)
void	basicConsume(AMQP.Basic.Consume basicConsume)
GetResponse	basicGet(AMQP.Basic.Get basicGet)
void	basicPublish(PublishRequest publishRequest)
void	basicQoS(AMQP.Basic.Qos qos)
void	basicRecover(boolean requeue, int channelNumber)
void	basicReject(AMQP.Basic.Reject basicReject)
void	channelClose(int channelNumber)
void	cleanConsumers(short sid)
private void	cleanQueueContext(int channelNumber, QueueShell queueShell)
private void	commitTx()
void	connectionClose()
boolean	deliver(String consumerTag, int channelNumber, Queue queue, short serverId, long proxyId)
private void	doCancel(String consumerTag, int channelNumber, QueueShell queueShell)
private int	doGetDeliveries(String consumerTag, int channelId, int maxMessage, Queue queue)
protected void	doProcessMethod(AbstractMarshallingMethod method)
void	exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare)
void	exchangeDelete(AMQP.Exchange.Delete exchangeDelete)
private ChannelContext	getContext(int channelNumber)
private void	getDeliveries(GetDeliveries getDeliveries)
Set<String>	getExclusiveQueues()
private static long	getNextProxyId()
Integer[]	getOpenedChannels()
int	getQueueInSize()
int	getQueueOutSize()
void	loadProxyId()
void	queueBind(AMQP.Queue.Bind queueBind)
AMQP.Queue.DeclareOk	queueDeclare(AMQP.Queue.Declare queueDeclare)
AMQP.Queue.DeleteOk	queueDelete(AMQP.Queue.Delete queueDelete)
AMQP.Queue.PurgeOk	queuePurge(AMQP.Queue.Purge queuePurge)
void	queueUnbind(AMQP.Queue.Unbind queueUnbind)
void	saveProxyId()
void	send(AbstractMarshallingMethod method)
void	send(Deliver deliver, QueueShell queue)
void	send(GetResponse response)
void	send(Returned response)
void	start()
void	stop()
private void	throwException(AMQPException amqe, int channelNumber, int classId, int methodId)	Releases connection or channel resources and close it by sending a notification to the client.
void	txCommit(int channelNumber)
void	txRollback(int channelNumber)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

PREFIX_PX

public static final String PREFIX_PX

See Also:

Constant Field Values

proxyId

private static volatile long proxyId

name

private ProxyName name

queueIn

private Queue queueIn

queueOut

private Queue queueOut

netServerIn

private Proxy.NetServerIn netServerIn

transaction

private Transaction transaction

exclusiveQueues

private Set<QueueShell> exclusiveQueues

channelContexts

private Map<Integer,ChannelContext> channelContexts

Constructor Detail

Proxy

public Proxy(Queue queueIn,
             Queue queueOut)
      throws IOException

Throws:

IOException

Method Detail

getNextProxyId

private static long getNextProxyId()

loadProxyId

public void loadProxyId()
                 throws IOException

Throws:

IOException

saveProxyId

public void saveProxyId()
                 throws IOException

Throws:

IOException

doProcessMethod

protected void doProcessMethod(AbstractMarshallingMethod method)
                        throws AMQPException

Parameters:

method -

Throws:

AMQPException

throwException

private void throwException(AMQPException amqe,
                            int channelNumber,
                            int classId,
                            int methodId)
                     throws AMQPException

Releases connection or channel resources and close it by sending a notification to the client.

Throws:

AMQPException

commitTx

private void commitTx()
               throws TransactionException

Throws:

TransactionException

getContext

private ChannelContext getContext(int channelNumber)

cleanConsumers

public void cleanConsumers(short sid)
                    throws AMQPException

Throws:

AMQPException

basicAck

public void basicAck(AMQP.Basic.Ack ack)
              throws PreconditionFailedException

Throws:

PreconditionFailedException

basicCancel

public void basicCancel(String consumerTag,
                        int channelNumber)
                 throws AMQPException,
                        ResourceLockedException

Throws:

AMQPException

ResourceLockedException

doCancel

private void doCancel(String consumerTag,
                      int channelNumber,
                      QueueShell queueShell)
               throws ResourceLockedException,
                      NotFoundException,
                      PreconditionFailedException,
                      AMQPException

Throws:

ResourceLockedException

NotFoundException

PreconditionFailedException

AMQPException

getDeliveries

private void getDeliveries(GetDeliveries getDeliveries)

doGetDeliveries

private int doGetDeliveries(String consumerTag,
                            int channelId,
                            int maxMessage,
                            Queue queue)

basicConsume

public void basicConsume(AMQP.Basic.Consume basicConsume)
                  throws NotFoundException,
                         NotAllowedException,
                         AMQPException,
                         AccessRefusedException,
                         ResourceLockedException

Throws:

NotFoundException

NotAllowedException

AMQPException

AccessRefusedException

ResourceLockedException

basicGet

public GetResponse basicGet(AMQP.Basic.Get basicGet)
                     throws NotFoundException,
                            AMQPException,
                            SyntaxErrorException,
                            ResourceLockedException

Throws:

NotFoundException

AMQPException

SyntaxErrorException

ResourceLockedException

basicPublish

public void basicPublish(PublishRequest publishRequest)
                  throws NotFoundException,
                         TransactionException

Throws:

NotFoundException

TransactionException

basicRecover

public void basicRecover(boolean requeue,
                         int channelNumber)
                  throws TransactionException

Throws:

TransactionException

basicReject

public void basicReject(AMQP.Basic.Reject basicReject)
                 throws TransactionException,
                        PreconditionFailedException

Throws:

TransactionException

PreconditionFailedException

basicQoS

public void basicQoS(AMQP.Basic.Qos qos)
              throws NotImplementedException

Throws:

NotImplementedException

channelClose

public void channelClose(int channelNumber)
                  throws AMQPException

Throws:

AMQPException

connectionClose

public void connectionClose()

exchangeDeclare

public void exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare)
                     throws CommandInvalidException,
                            NotAllowedException,
                            NotFoundException,
                            AMQPException

Throws:

CommandInvalidException

NotAllowedException

NotFoundException

AMQPException

exchangeDelete

public void exchangeDelete(AMQP.Exchange.Delete exchangeDelete)
                    throws NotFoundException,
                           PreconditionFailedException,
                           AMQPException

Throws:

NotFoundException

PreconditionFailedException

AMQPException

queueBind

public void queueBind(AMQP.Queue.Bind queueBind)
               throws NotFoundException,
                      SyntaxErrorException,
                      ResourceLockedException,
                      AMQPException

Throws:

NotFoundException

SyntaxErrorException

ResourceLockedException

AMQPException

queueDeclare

public AMQP.Queue.DeclareOk queueDeclare(AMQP.Queue.Declare queueDeclare)
                                  throws NotFoundException,
                                         ResourceLockedException,
                                         AMQPException

Throws:

NotFoundException

ResourceLockedException

AMQPException

queueDelete

public AMQP.Queue.DeleteOk queueDelete(AMQP.Queue.Delete queueDelete)
                                throws NotFoundException,
                                       PreconditionFailedException,
                                       ResourceLockedException,
                                       AMQPException

Throws:

NotFoundException

PreconditionFailedException

ResourceLockedException

AMQPException

cleanQueueContext

private void cleanQueueContext(int channelNumber,
                               QueueShell queueShell)

queuePurge

public AMQP.Queue.PurgeOk queuePurge(AMQP.Queue.Purge queuePurge)
                              throws NotFoundException,
                                     NotAllowedException,
                                     ResourceLockedException,
                                     SyntaxErrorException,
                                     AMQPException

Throws:

NotFoundException

NotAllowedException

ResourceLockedException

SyntaxErrorException

AMQPException

queueUnbind

public void queueUnbind(AMQP.Queue.Unbind queueUnbind)
                 throws NotFoundException,
                        AMQPException

Throws:

NotFoundException

AMQPException

txCommit

public void txCommit(int channelNumber)
              throws PreconditionFailedException,
                     TransactionException

Throws:

PreconditionFailedException

TransactionException

txRollback

public void txRollback(int channelNumber)
                throws PreconditionFailedException

Throws:

PreconditionFailedException

deliver

public boolean deliver(String consumerTag,
                       int channelNumber,
                       Queue queue,
                       short serverId,
                       long proxyId)

Specified by:

deliver in interface DeliveryListener

send

public void send(AbstractMarshallingMethod method)

send

public void send(GetResponse response)

send

public void send(Deliver deliver,
                 QueueShell queue)

send

public void send(Returned response)

stop

public void stop()

start

public void start()

getQueueInSize

public int getQueueInSize()

Specified by:

getQueueInSize in interface ProxyMBean

getQueueOutSize

public int getQueueOutSize()

Specified by:

getQueueOutSize in interface ProxyMBean

getExclusiveQueues

public Set<String> getExclusiveQueues()

Specified by:

getExclusiveQueues in interface ProxyMBean

getOpenedChannels

public Integer[] getOpenedChannels()

Specified by:

getOpenedChannels in interface ProxyMBean