org.fusesource.stomp.jms
Class TxMessageQueue

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

public class TxMessageQueue
extends MessageQueue

Author:

Hiram Chirino

Nested Class Summary

Nested classes/interfaces inherited from class org.fusesource.stomp.jms.MessageQueue

MessageQueue.QueueEntry

Field Summary

Fields inherited from class org.fusesource.stomp.jms.MessageQueue

closed, list, maxSize, running, size

Constructor Summary

TxMessageQueue(long maxSize)

Method Summary

void	commit()
protected void	removed(MessageQueue.QueueEntry entry)
void	rollback()

Methods inherited from class org.fusesource.stomp.jms.MessageQueue

clear, close, dequeue, dequeueNoWait, enqueue, isClosed, isEmpty, isFull, isRunning, removeAll, size, start, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TxMessageQueue

public TxMessageQueue(long maxSize)

Method Detail

removed

protected void removed(MessageQueue.QueueEntry entry)

Overrides:

removed in class MessageQueue

commit

public void commit()

rollback

public void rollback()