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: 1.32 $ $Id: Queue.java,v 1.32 2006/06/27 19:44:40 timfox Exp $

Author:

Ovidiu Feodorov, Tim Fox

Field Summary

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

channelID, mm, ms, pm, router, state

Constructor Summary

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

Method Summary

int	getDownCacheSize()
int	getFullSize()
long	getId()
int	getMessageCount()
int	getPageSize()
boolean	isQueue()
void	load()
java.lang.String	toString()

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

acceptReliableMessages, acknowledge, add, browse, browse, cancel, clear, close, contains, deliver, deliver, deliver, getChannelID, getMessageStore, handle, isRecoverable, iterator, obtainReference, processMessageBeforeStorage, remove, removeAllMessages

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)

Method Detail

toString

public java.lang.String toString()

load

public void load()
          throws java.lang.Exception

Throws:

java.lang.Exception

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