org.jboss.messaging.core.local
Class PagingFilteredQueue
java.lang.Object
org.jboss.messaging.core.ChannelSupport
org.jboss.messaging.core.PagingChannelSupport
org.jboss.messaging.core.local.PagingFilteredQueue
- All Implemented Interfaces:
- Channel, DeliveryObserver, Distributor, Queue, Receiver
- Direct Known Subclasses:
- LocalClusteredQueue
- public class PagingFilteredQueue
- extends PagingChannelSupport
- implements Queue
A PagingFilteredQueue
Can be used to implement a point to point queue, or a subscription fed from a topic
- Version:
- $Revision: 1295 $
$Id: Queue.java 1295 2006-09-15 17:44:02Z timfox $
- Author:
- Ovidiu Feodorov, Tim Fox
Fields inherited from class org.jboss.messaging.core.ChannelSupport |
acceptReliableMessages, active, channelID, deliveringCount, maxSize, messageRefs, messagesAdded, ms, pm, receiversReady, recoverable, refLock, router, scheduledDeliveries |
Constructor Summary |
PagingFilteredQueue(java.lang.String name,
long id,
MessageStore ms,
PersistenceManager pm,
boolean acceptReliableMessages,
boolean recoverable,
int maxSize,
Filter filter)
|
PagingFilteredQueue(java.lang.String name,
long id,
MessageStore ms,
PersistenceManager pm,
boolean acceptReliableMessages,
boolean recoverable,
int maxSize,
Filter filter,
int fullSize,
int pageSize,
int downCacheSize)
|
Methods inherited from class org.jboss.messaging.core.PagingChannelSupport |
addFromRefInfo, addReferenceInMemory, addToDownCache, cancelInternal, doLoad, downCacheCount, flushDownCache, getMessageCount, isActive, isPaging, load, loadPagedReferences, processReferences, removeFirstInMemory, setPagingParams, unload |
Methods inherited from class org.jboss.messaging.core.ChannelSupport |
acceptReliableMessages, acknowledge, acknowledgeInternal, activate, add, browse, browse, cancel, checkAndSchedule, checkClosed, clear, clearAllScheduledDeliveries, close, contains, deactivate, deliver, deliverInternal, deliverScheduled, getCallback, getChannelID, getDeliveringCount, getMaxSize, getMessagesAdded, getNumberOfReceivers, getScheduledCount, handleInternal, isRecoverable, iterator, memoryRefCount, processMessageBeforeStorage, recoverDeliveries, remove, removeAllReferences, setMaxSize, undelivered |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.jboss.messaging.core.Channel |
acceptReliableMessages, activate, browse, browse, clear, close, deactivate, deliver, getChannelID, getDeliveringCount, getMaxSize, getMessageCount, getMessagesAdded, getScheduledCount, isActive, isRecoverable, load, recoverDeliveries, removeAllReferences, setMaxSize, unload |
name
protected java.lang.String name
filter
protected Filter filter
PagingFilteredQueue
public PagingFilteredQueue(java.lang.String name,
long id,
MessageStore ms,
PersistenceManager pm,
boolean acceptReliableMessages,
boolean recoverable,
int maxSize,
Filter filter)
PagingFilteredQueue
public PagingFilteredQueue(java.lang.String name,
long id,
MessageStore ms,
PersistenceManager pm,
boolean acceptReliableMessages,
boolean recoverable,
int maxSize,
Filter filter,
int fullSize,
int pageSize,
int downCacheSize)
isClustered
public boolean isClustered()
- Specified by:
isClustered
in interface Queue
getName
public java.lang.String getName()
- Specified by:
getName
in interface Queue
getFilter
public Filter getFilter()
- Specified by:
getFilter
in interface Queue
handle
public Delivery handle(DeliveryObserver sender,
MessageReference ref,
Transaction tx)
- Description copied from interface:
Receiver
- A receiver can return an active, "done" or null delivery. The method returns null in case
the receiver doesn't accept the message. The return value is unspecified when the
message is submitted in the context of a transaction (tx not null).
- Specified by:
handle
in interface Receiver
- Overrides:
handle
in class ChannelSupport
toString
public java.lang.String toString()
- Overrides:
toString
in class ChannelSupport
Copyright © 2006 JBoss Inc. All Rights Reserved.