org.fusesource.stompjms
Class MessageQueue

java.lang.Object
  org.fusesource.stompjms.MessageQueue

public class MessageQueue
extends java.lang.Object

Constructor Summary

MessageQueue()

Method Summary

void	clear()
void	close()
StompJmsMessage	dequeue(long timeout)
StompJmsMessage	dequeueNoWait()
void	enqueue(StompJmsMessage message)
void	enqueueFirst(StompJmsMessage message)
java.lang.Object	getMutex()
boolean	isClosed()
boolean	isEmpty()
boolean	isRunning()
StompJmsMessage	peek()
java.util.List<StompJmsMessage>	removeAll()
void	rollback(org.fusesource.hawtbuf.AsciiBuffer transactionId)
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

Constructor Detail

MessageQueue

public MessageQueue()

Method Detail

enqueue

public void enqueue(StompJmsMessage message)

enqueueFirst

public void enqueueFirst(StompJmsMessage message)

isEmpty

public boolean isEmpty()

dequeue

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

Throws:

java.lang.InterruptedException

dequeueNoWait

public StompJmsMessage dequeueNoWait()

peek

public StompJmsMessage peek()

start

public void start()

stop

public void stop()

close

public void close()

clear

public void clear()

isClosed

public boolean isClosed()

size

public int size()

getMutex

public java.lang.Object getMutex()

isRunning

public boolean isRunning()

removeAll

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

rollback

public void rollback(org.fusesource.hawtbuf.AsciiBuffer transactionId)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object