org.jboss.messaging.core.local
Class CoreSubscription
java.lang.Object
org.jboss.messaging.core.ChannelSupport
org.jboss.messaging.core.local.Pipe
org.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 $
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)
|
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 |
topic
protected Topic topic
filter
protected Filter filter
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)
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.