Package org.ow2.joram.mom.amqp

Class Queue

java.lang.Object

org.ow2.joram.mom.amqp.Queue

All Implemented Interfaces:

Externalizable, Serializable, QueueMBean

public class Queue
extends Object
implements QueueMBean, Externalizable

An AMQP queue.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	Queue.Subscription
private static class	Queue.SubscriptionKey

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	autodelete
private List<String>	boundExchanges
private Map<Queue.SubscriptionKey,Queue.Subscription>	consumers
private boolean	durable
private boolean	exclusive
static long	FIRST_DELIVERY
static Logger	logger
private long	msgCounter
private String	name
private static String	PREFIX_BOUND_EXCHANGE
private static String	PREFIX_MSG
static String	PREFIX_QUEUE
private String	prefixBE
private String	prefixMsg
private long	proxyId
private static long	serialVersionUID	define serialVersionUID for interoperability
private short	serverId
private SortedSet<Message>	toAck
private SortedSet<Message>	toDeliver

Constructor Summary

Constructors

Constructor	Description
Queue()
Queue(String name, boolean durable, boolean autodelete, boolean exclusive, short serverId, long proxyId)

Method Summary

Modifier and Type	Method	Description
void	ackMessages(List<Long> idsToAck)
void	addBoundExchange(String exchange, short serverId, long proxyId)
void	cancel(String consumerTag, int channelNumber, short serverId, long proxyId)
void	cleanConsumers(short sid)
int	clear(short serverId, long proxyId)
void	consume(DeliveryListener proxy, int channelId, String consumerTag, boolean exclusiveConsumer, boolean noAck, boolean noLocal, short serverId, long proxyId)
private void	deleteAllMessage(Set<Message> messages)
private void	deleteBoundExchange(String exchangeName)
private void	deleteMessage(long msgId)
void	deleteQueue(String queueName, short serverId, long proxyId)
List<String>	getBoundExchanges()
int	getConsumerCount()
List<Deliver>	getDeliveries(String consumerTag, int channelId, int maxMessage, short serverId, long proxyId)
long	getHandledMessageCount()
AMQP.Queue.DeclareOk	getInfo(short serverId, long proxyId)
String	getName()
int	getToAckMessageCount()
int	getToDeliverMessageCount()
boolean	isAutodelete()
boolean	isDurable()
boolean	isExclusive()
static Queue	loadQueue(String name)
void	publish(Message msg, boolean immediate, short serverId, long proxyId)
void	readExternal(ObjectInput in)
Message	receive(boolean noAck, short serverId, long proxyId)
void	recoverMessages(List<Long> idsToRecover)
void	removeBoundExchange(String exchangeName)
void	removeBoundExchange(String exchangeName, short serverId, long proxyId)
private void	saveBoundExchange(String exchange)
private void	saveMessage(Message msg)
private void	saveQueue(Queue queue)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

logger

public static final Logger logger

serialVersionUID

private static final long serialVersionUID

define serialVersionUID for interoperability

See Also:

Constant Field Values

FIRST_DELIVERY

public static final long FIRST_DELIVERY

See Also:

Constant Field Values

name

private String name

durable

private boolean durable

autodelete

private boolean autodelete

exclusive

private boolean exclusive

boundExchanges

private List<String> boundExchanges

serverId

private short serverId

proxyId

private long proxyId

msgCounter

private long msgCounter

toDeliver

private SortedSet<Message> toDeliver

toAck

private SortedSet<Message> toAck

consumers

private Map<Queue.SubscriptionKey,Queue.Subscription> consumers

PREFIX_QUEUE

public static final String PREFIX_QUEUE

See Also:

Constant Field Values

PREFIX_MSG

private static final String PREFIX_MSG

See Also:

Constant Field Values

PREFIX_BOUND_EXCHANGE

private static final String PREFIX_BOUND_EXCHANGE

See Also:

Constant Field Values

prefixMsg

private String prefixMsg

prefixBE

private String prefixBE

Constructor Detail

Queue

public Queue()

Queue

public Queue(String name,
             boolean durable,
             boolean autodelete,
             boolean exclusive,
             short serverId,
             long proxyId)
      throws TransactionException

Throws:

TransactionException

Method Detail

receive

public Message receive(boolean noAck,
                       short serverId,
                       long proxyId)
                throws ResourceLockedException,
                       TransactionException

Throws:

ResourceLockedException

TransactionException

consume

public void consume(DeliveryListener proxy,
                    int channelId,
                    String consumerTag,
                    boolean exclusiveConsumer,
                    boolean noAck,
                    boolean noLocal,
                    short serverId,
                    long proxyId)
             throws AccessRefusedException,
                    ResourceLockedException

Throws:

AccessRefusedException

ResourceLockedException

getDeliveries

public List<Deliver> getDeliveries(String consumerTag,
                                   int channelId,
                                   int maxMessage,
                                   short serverId,
                                   long proxyId)

publish

public void publish(Message msg,
                    boolean immediate,
                    short serverId,
                    long proxyId)
             throws NoConsumersException,
                    TransactionException

Throws:

NoConsumersException

TransactionException

cancel

public void cancel(String consumerTag,
                   int channelNumber,
                   short serverId,
                   long proxyId)
            throws ResourceLockedException

Throws:

ResourceLockedException

cleanConsumers

public void cleanConsumers(short sid)

clear

public int clear(short serverId,
                 long proxyId)
          throws ResourceLockedException,
                 TransactionException

Throws:

ResourceLockedException

TransactionException

ackMessages

public void ackMessages(List<Long> idsToAck)

recoverMessages

public void recoverMessages(List<Long> idsToRecover)
                     throws TransactionException

Throws:

TransactionException

getInfo

public AMQP.Queue.DeclareOk getInfo(short serverId,
                                    long proxyId)
                             throws ResourceLockedException

Throws:

ResourceLockedException

getName

public String getName()

Specified by:

getName in interface QueueMBean

getConsumerCount

public int getConsumerCount()

Specified by:

getConsumerCount in interface QueueMBean

isAutodelete

public boolean isAutodelete()

Specified by:

isAutodelete in interface QueueMBean

getToDeliverMessageCount

public int getToDeliverMessageCount()

Specified by:

getToDeliverMessageCount in interface QueueMBean

getToAckMessageCount

public int getToAckMessageCount()

Specified by:

getToAckMessageCount in interface QueueMBean

getHandledMessageCount

public long getHandledMessageCount()

Specified by:

getHandledMessageCount in interface QueueMBean

getBoundExchanges

public List<String> getBoundExchanges()

Specified by:

getBoundExchanges in interface QueueMBean

isDurable

public boolean isDurable()

Specified by:

isDurable in interface QueueMBean

isExclusive

public boolean isExclusive()

Specified by:

isExclusive in interface QueueMBean

addBoundExchange

public void addBoundExchange(String exchange,
                             short serverId,
                             long proxyId)
                      throws TransactionException,
                             ResourceLockedException

Throws:

TransactionException

ResourceLockedException

removeBoundExchange

public void removeBoundExchange(String exchangeName)

removeBoundExchange

public void removeBoundExchange(String exchangeName,
                                short serverId,
                                long proxyId)
                         throws ResourceLockedException

Throws:

ResourceLockedException

deleteQueue

public void deleteQueue(String queueName,
                        short serverId,
                        long proxyId)
                 throws ResourceLockedException,
                        TransactionException

Throws:

ResourceLockedException

TransactionException

loadQueue

public static Queue loadQueue(String name)
                       throws IOException,
                              ClassNotFoundException,
                              TransactionException

Throws:

IOException

ClassNotFoundException

TransactionException

saveQueue

private void saveQueue(Queue queue)
                throws TransactionException

Throws:

TransactionException

saveBoundExchange

private void saveBoundExchange(String exchange)
                        throws TransactionException

Throws:

TransactionException

deleteBoundExchange

private void deleteBoundExchange(String exchangeName)

deleteAllMessage

private void deleteAllMessage(Set<Message> messages)

saveMessage

private void saveMessage(Message msg)
                  throws TransactionException

Throws:

TransactionException

deleteMessage

private void deleteMessage(long msgId)

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