org.jboss.messaging.core.local
Class CoreSubscription

java.lang.Object
  extended byorg.jboss.messaging.core.ChannelSupport
      extended byorg.jboss.messaging.core.local.Pipe
          extended byorg.jboss.messaging.core.local.CoreSubscription
All Implemented Interfaces:
Channel, DeliveryObserver, Distributor, Receiver
Direct Known Subclasses:
Subscription

public class CoreSubscription
extends Pipe

Represents a subscription to a destination (topic or queue).

Author:
Tim Fox $Id: CoreSubscription.java 1019 2006-07-17 17:15:04Z timfox $

Field Summary
protected  Filter filter
           
protected  Topic 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
CoreSubscription(long id, Topic topic, MessageStore ms, PersistenceManager pm, MemoryManager mm, boolean recoverable, int fullSize, int pageSize, int downCacheSize, QueuedExecutor executor, Filter filter)
           
 
Method Summary
 void connect()
           
 void disconnect()
           
 Topic getTopic()
           
 Delivery handle(DeliveryObserver sender, Routable r, Transaction tx)
          A receiver can return an active, "done" or null delivery.
 java.lang.String 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

topic

protected Topic topic

filter

protected Filter filter
Constructor Detail

CoreSubscription

public CoreSubscription(long id,
                        Topic topic,
                        MessageStore ms,
                        PersistenceManager pm,
                        MemoryManager mm,
                        boolean recoverable,
                        int fullSize,
                        int pageSize,
                        int downCacheSize,
                        QueuedExecutor executor,
                        Filter filter)
Method Detail

handle

public Delivery handle(DeliveryObserver sender,
                       Routable r,
                       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

connect

public void connect()

disconnect

public void disconnect()

getTopic

public Topic getTopic()

toString

public java.lang.String toString()
Overrides:
toString in class Pipe


Copyright © 2006 JBoss Inc. All Rights Reserved.