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

Constructors

Constructor and Description
TxMessageQueue(long maxSize)

Method Summary

Methods

Modifier and Type	Method and Description
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()