org.fusesource.stomp.jms
Class MessageQueue

java.lang.Object
  org.fusesource.stomp.jms.MessageQueue

Direct Known Subclasses:

TxMessageQueue

public class MessageQueue
extends java.lang.Object

Nested Class Summary

protected static class

MessageQueue.QueueEntry

Field Summary

protected boolean	closed
protected java.util.LinkedList<MessageQueue.QueueEntry>	list
protected long	maxSize
protected boolean	running
protected long	size

Constructor Summary

MessageQueue(long maxSize)

Method Summary

void	clear()
void	close()
StompJmsMessage	dequeue(long timeout)
StompJmsMessage	dequeueNoWait()
void	enqueue(StompJmsMessage message)
boolean	isClosed()
boolean	isEmpty()
boolean	isFull()
boolean	isRunning()
java.util.List<StompJmsMessage>	removeAll()
protected void	removed(MessageQueue.QueueEntry entry)
int	size()
void	start()
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

maxSize

protected final long maxSize

list

protected final java.util.LinkedList<MessageQueue.QueueEntry> list

closed

protected boolean closed

running

protected boolean running

size

protected long size

Constructor Detail

MessageQueue

public MessageQueue(long maxSize)

Method Detail

enqueue

public void enqueue(StompJmsMessage message)

isEmpty

public boolean isEmpty()

dequeue

public StompJmsMessage dequeue(long timeout)
                        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

dequeueNoWait

public StompJmsMessage dequeueNoWait()

removed

protected void removed(MessageQueue.QueueEntry entry)

start

public void start()

stop

public void stop()

isRunning

public boolean isRunning()

close

public void close()

isClosed

public boolean isClosed()

size

public int size()

clear

public void clear()

removeAll

public java.util.List<StompJmsMessage> removeAll()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

isFull

public boolean isFull()