org.jboss.messaging.core.server
Interface Queue

All Known Implementing Classes:

QueueImpl, QueueImpl_c, QueueImpl_nc

public interface Queue

A Queue

Author:

Tim Fox, Andy Taylor

Field Summary

static int

NUM_PRIORITIES

Method Summary

void	addConsumer(Consumer consumer)
HandleStatus	addFirst(MessageReference ref)
HandleStatus	addLast(MessageReference ref)
void	addListFirst(java.util.LinkedList<MessageReference> list) This method is used to add a List of MessageReferences atomically at the head of the list.
void	deleteAllReferences(StorageManager storageManager)
void	deliver()
void	deliverAsync(java.util.concurrent.Executor executor)
int	getConsumerCount()
int	getDeliveringCount()
DistributionPolicy	getDistributionPolicy()
Filter	getFilter()
FlowController	getFlowController()
int	getMaxSizeBytes()
int	getMessageCount()
int	getMessagesAdded()
SimpleString	getName()
long	getPersistenceID()
MessageReference	getReference(long id)
int	getScheduledCount()
int	getSizeBytes()
boolean	isClustered()
boolean	isDurable()
boolean	isTemporary()
java.util.List<MessageReference>	list(Filter filter)
void	referenceAcknowledged(MessageReference ref)
void	referenceCancelled()
boolean	removeConsumer(Consumer consumer)
boolean	removeReferenceWithID(long id)
void	setDistributionPolicy(DistributionPolicy policy)
void	setFilter(Filter filter)
void	setFlowController(FlowController flowController)
void	setPersistenceID(long id)

Field Detail

NUM_PRIORITIES

static final int NUM_PRIORITIES

See Also:

Constant Field Values

Method Detail

addLast

HandleStatus addLast(MessageReference ref)

addFirst

HandleStatus addFirst(MessageReference ref)

addListFirst

void addListFirst(java.util.LinkedList<MessageReference> list)

This method is used to add a List of MessageReferences atomically at the head of the list. Useful when cancelling messages and guaranteeing ordering

Parameters:

list -

deliver

void deliver()

deliverAsync

void deliverAsync(java.util.concurrent.Executor executor)

addConsumer

void addConsumer(Consumer consumer)

removeConsumer

boolean removeConsumer(Consumer consumer)

getConsumerCount

int getConsumerCount()

list

java.util.List<MessageReference> list(Filter filter)

getPersistenceID

long getPersistenceID()

setPersistenceID

void setPersistenceID(long id)

getFilter

Filter getFilter()

setFilter

void setFilter(Filter filter)

getMessageCount

int getMessageCount()

getDeliveringCount

int getDeliveringCount()

referenceAcknowledged

void referenceAcknowledged(MessageReference ref)
                           throws java.lang.Exception

Throws:

java.lang.Exception

referenceCancelled

void referenceCancelled()

getScheduledCount

int getScheduledCount()

getMaxSizeBytes

int getMaxSizeBytes()

getSizeBytes

int getSizeBytes()

getDistributionPolicy

DistributionPolicy getDistributionPolicy()

setDistributionPolicy

void setDistributionPolicy(DistributionPolicy policy)

isClustered

boolean isClustered()

isTemporary

boolean isTemporary()

isDurable

boolean isDurable()

getName

SimpleString getName()

getMessagesAdded

int getMessagesAdded()

getFlowController

FlowController getFlowController()

setFlowController

void setFlowController(FlowController flowController)

removeReferenceWithID

boolean removeReferenceWithID(long id)

getReference

MessageReference getReference(long id)

deleteAllReferences

void deleteAllReferences(StorageManager storageManager)
                         throws java.lang.Exception

Throws:

java.lang.Exception