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
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.Receiver |
handle |
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()
Copyright © 2006 JBoss Inc. All Rights Reserved.