org.jboss.jms.server.subscription
Class DurableSubscription

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
                  org.jboss.jms.server.subscription.DurableSubscription

All Implemented Interfaces:

Channel, DeliveryObserver, Distributor, Receiver

public class DurableSubscription

extends Subscription

A DurableSubscription.

Version:

$Revision: 1174 $ $Id: DurableSubscription.java 1174 2006-08-02 14:14:32Z timfox $

Author:

Tim Fox

Field Summary

protected java.lang.String	clientID
protected java.lang.String	name

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

DurableSubscription(long id, Topic topic, MessageStore ms, PersistenceManager pm, MemoryManager mm, int fullSize, int pageSize, int downCacheSize, QueuedExecutor executor, Selector selector, boolean isNoLocal, java.lang.String name, java.lang.String clientID)

Method Summary

java.lang.String	getClientID()
java.lang.String	getName()
void	unsubscribe()

Methods inherited from class org.jboss.jms.server.subscription.Subscription

getSelector, 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

Field Detail

name

protected java.lang.String name

clientID

protected java.lang.String clientID

Constructor Detail

DurableSubscription

public DurableSubscription(long id,
                           Topic topic,
                           MessageStore ms,
                           PersistenceManager pm,
                           MemoryManager mm,
                           int fullSize,
                           int pageSize,
                           int downCacheSize,
                           QueuedExecutor executor,
                           Selector selector,
                           boolean isNoLocal,
                           java.lang.String name,
                           java.lang.String clientID)

Method Detail

getName

public java.lang.String getName()

getClientID

public java.lang.String getClientID()

unsubscribe

public void unsubscribe()
                 throws java.lang.Throwable

Throws:

java.lang.Throwable