org.jboss.messaging.core.local
Class PagingFilteredQueue

java.lang.Object
  extended byorg.jboss.messaging.core.ChannelSupport
      extended byorg.jboss.messaging.core.PagingChannelSupport
          extended byorg.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

Field Summary
protected  Filter filter
           
protected  java.lang.String name
           
 
Fields inherited from class org.jboss.messaging.core.PagingChannelSupport
downCache, downCacheSize, firstPagingOrder, fullSize, nextPagingOrder, pageSize, paging
 
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)
           
 
Method Summary
 Filter getFilter()
           
 java.lang.String getName()
           
 Delivery handle(DeliveryObserver sender, MessageReference ref, Transaction tx)
          A receiver can return an active, "done" or null delivery.
 boolean isClustered()
           
 java.lang.String toString()
           
 
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
 
Methods inherited from interface org.jboss.messaging.core.DeliveryObserver
acknowledge, cancel
 
Methods inherited from interface org.jboss.messaging.core.Distributor
add, contains, getNumberOfReceivers, iterator, remove
 

Field Detail

name

protected java.lang.String name

filter

protected Filter filter
Constructor Detail

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)
Method Detail

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.