org.jboss.jms.server.subscription
Class Subscription

java.lang.Object
  org.jboss.messaging.core.ChannelSupport
      org.jboss.messaging.core.local.Pipe
          org.jboss.messaging.core.local.CoreSubscription
              org.jboss.jms.server.subscription.Subscription

All Implemented Interfaces:

Channel, DeliveryObserver, Distributor, Receiver

Direct Known Subclasses:

DurableSubscription

public class Subscription

extends CoreSubscription

A Subscription.

Version:

$Revision: 1019 $ $Id: Subscription.java 1019 2006-07-17 17:15:04Z timfox $

Author:

Tim Fox

Field Summary

Fields inherited from class org.jboss.messaging.core.local.CoreSubscription

filter, topic

Fields inherited from class org.jboss.messaging.core.ChannelSupport

acceptReliableMessages, channelID, deliveries, downCache, downCacheSize, executor, fullSize, messageOrdering, messageRefs, mm, ms, pageSize, paging, pm, receiversReady, recoverable, refsInStorage, router

Constructor Summary

protected	Subscription(long id, Topic topic, MessageStore ms, PersistenceManager pm, MemoryManager mm, boolean recoverable, int fullSize, int pageSize, int downCacheSize, QueuedExecutor executor, Selector selector, boolean isNoLocal)
	Subscription(long id, Topic topic, MessageStore ms, PersistenceManager pm, MemoryManager mm, int fullSize, int pageSize, int downCacheSize, QueuedExecutor executor, Selector selector, boolean isNoLocal)

Method Summary

java.lang.String	getSelector()
boolean	isNoLocal()

Methods inherited from class org.jboss.messaging.core.local.CoreSubscription

connect, disconnect, getTopic, handle, toString

Methods inherited from class org.jboss.messaging.core.ChannelSupport

acceptReliableMessages, acknowledge, acknowledgeInMemory, acknowledgeInternal, add, addReferenceInMemory, addToDownCache, browse, browse, cancel, cancelInternal, checkMemory, clear, close, contains, deliver, delivering, deliverInternal, downCacheCount, flushDownCache, getCallback, getChannelID, handleInternal, isPaging, isRecoverable, iterator, load, load, memoryDeliveryCount, memoryRefCount, messageCount, obtainReference, processMessageBeforeStorage, remove, removeAllReferences, removeFirstInMemory, undelivered

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Subscription

public Subscription(long id,
                    Topic topic,
                    MessageStore ms,
                    PersistenceManager pm,
                    MemoryManager mm,
                    int fullSize,
                    int pageSize,
                    int downCacheSize,
                    QueuedExecutor executor,
                    Selector selector,
                    boolean isNoLocal)

Subscription

protected Subscription(long id,
                       Topic topic,
                       MessageStore ms,
                       PersistenceManager pm,
                       MemoryManager mm,
                       boolean recoverable,
                       int fullSize,
                       int pageSize,
                       int downCacheSize,
                       QueuedExecutor executor,
                       Selector selector,
                       boolean isNoLocal)

Method Detail

getSelector

public java.lang.String getSelector()

isNoLocal

public boolean isNoLocal()