org.jboss.messaging.core.local
Class Queue

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

All Implemented Interfaces:

Channel, CoreDestination, DeliveryObserver, Distributor, Receiver

Direct Known Subclasses:

DistributedQueue

public class Queue

extends ChannelSupport

implements CoreDestination

Version:

$Revision: 1183 $ $Id: Queue.java 1183 2006-08-03 11:33:15Z timfox $

Author:

Ovidiu Feodorov, Tim Fox

Field Summary

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

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

Constructor Summary

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

Method Summary

int	getDownCacheSize()
int	getFullSize()
long	getId()
int	getMessageCount()
int	getPageSize()
boolean	isQueue()
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

Methods inherited from interface org.jboss.messaging.core.Distributor

add, clear, contains, iterator, remove

Methods inherited from interface org.jboss.messaging.core.Receiver

handle

Constructor Detail

Queue

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

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class ChannelSupport

isQueue

public boolean isQueue()

Specified by:

isQueue in interface CoreDestination

Returns:

true if the CoreDestination represents a Queue

getMessageCount

public int getMessageCount()

getId

public long getId()

Specified by:

getId in interface CoreDestination

getFullSize

public int getFullSize()

Specified by:

getFullSize in interface CoreDestination

getPageSize

public int getPageSize()

Specified by:

getPageSize in interface CoreDestination

getDownCacheSize

public int getDownCacheSize()

Specified by:

getDownCacheSize in interface CoreDestination