org.jboss.messaging.core.contract
Interface Queue

All Superinterfaces:

Channel, DeliveryObserver, Receiver

All Known Implementing Classes:

MessagingQueue

public interface Queue
extends Channel

A Queue

Version:

$Revision: 2862 $ $Id: Queue.java 2862 2007-07-09 21:57:24Z timfox $

Author:

Tim Fox

Method Summary

void	addAllToRecoveryArea(int nodeID, java.util.Map ids)
void	addToRecoveryArea(int nodeID, long messageID, java.lang.String sessionID)
int	getDownCacheSize()
Filter	getFilter()
int	getFullSize()
Distributor	getLocalDistributor()
java.lang.String	getName()
int	getNodeID()
int	getPageSize()
long	getRecoverDeliveriesTimeout()
java.util.Map	getRecoveryArea()
int	getRecoveryMapSize()
Distributor	getRemoteDistributor()
boolean	isClustered()
void	mergeIn(long channelID, int nodeID) Merge the contents of one queue with another - this happens at failover when a queue is failed over to another node, but a queue with the same name already exists.
java.util.List	recoverDeliveries(java.util.List messageIds)
void	registerSucker(MessageSucker sucker)
void	removeAllFromRecoveryArea(int nodeID)
void	removeFromRecoveryArea(int nodeID, long messageID)
void	removeStrandedReferences(java.lang.String sessionID)
void	setPagingParams(int fullSize, int pageSize, int downCacheSize)
boolean	unregisterSucker(MessageSucker sucker)

Methods inherited from interface org.jboss.messaging.core.contract.Channel

activate, browse, close, deactivate, deliver, getChannelID, getDeliveringCount, getMaxSize, getMessageCount, getMessagesAdded, getScheduledCount, isActive, isRecoverable, load, removeAllReferences, setMaxSize, unload

Methods inherited from interface org.jboss.messaging.core.contract.DeliveryObserver

acknowledge, cancel

Methods inherited from interface org.jboss.messaging.core.contract.Receiver

handle

Method Detail

getFilter

Filter getFilter()

mergeIn

void mergeIn(long channelID,
             int nodeID)
             throws java.lang.Exception

Merge the contents of one queue with another - this happens at failover when a queue is failed over to another node, but a queue with the same name already exists. In this case we merge the two queues.

Throws:

java.lang.Exception

setPagingParams

void setPagingParams(int fullSize,
                     int pageSize,
                     int downCacheSize)

getFullSize

int getFullSize()

getPageSize

int getPageSize()

getDownCacheSize

int getDownCacheSize()

isClustered

boolean isClustered()

getName

java.lang.String getName()

getNodeID

int getNodeID()

getRecoverDeliveriesTimeout

long getRecoverDeliveriesTimeout()

getLocalDistributor

Distributor getLocalDistributor()

getRemoteDistributor

Distributor getRemoteDistributor()

registerSucker

void registerSucker(MessageSucker sucker)

unregisterSucker

boolean unregisterSucker(MessageSucker sucker)

addToRecoveryArea

void addToRecoveryArea(int nodeID,
                       long messageID,
                       java.lang.String sessionID)

removeFromRecoveryArea

void removeFromRecoveryArea(int nodeID,
                            long messageID)

removeAllFromRecoveryArea

void removeAllFromRecoveryArea(int nodeID)

addAllToRecoveryArea

void addAllToRecoveryArea(int nodeID,
                          java.util.Map ids)

recoverDeliveries

java.util.List recoverDeliveries(java.util.List messageIds)

removeStrandedReferences

void removeStrandedReferences(java.lang.String sessionID)

getRecoveryArea

java.util.Map getRecoveryArea()

getRecoveryMapSize

int getRecoveryMapSize()