org.jboss.messaging.core.local
Class Pipe

java.lang.Object
  org.jboss.messaging.core.ChannelSupport
      org.jboss.messaging.core.local.Pipe

All Implemented Interfaces:

Channel, DeliveryObserver, Distributor, Receiver

Direct Known Subclasses:

CoreSubscription

public class Pipe

extends ChannelSupport

Version:

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

Author:

Ovidiu Feodorov, Tim Fox

Field Summary

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

Pipe(long id, MessageStore ms, PersistenceManager pm, MemoryManager mm, boolean acceptReliableMessages, boolean recoverable, int fullSize, int pageSize, int downCacheSize, QueuedExecutor executor)

Method Summary

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

Pipe

public Pipe(long id,
            MessageStore ms,
            PersistenceManager pm,
            MemoryManager mm,
            boolean acceptReliableMessages,
            boolean recoverable,
            int fullSize,
            int pageSize,
            int downCacheSize,
            QueuedExecutor executor)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class ChannelSupport