Class TopicSubscriberTransaction

java.lang.Object

com.swiftmq.impl.topic.standard.TopicSubscriberTransaction

public class TopicSubscriberTransaction
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TopicSubscriberTransaction(TopicSubscription topicSubscription, com.swiftmq.swiftlet.queue.QueuePushTransaction transaction, String destination)

Method Summary

Modifier and Type	Method	Description
protected long	commit()
protected long	commit(com.swiftmq.jms.XidImpl globalTxId)
protected void	commit(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
protected TopicSubscription	getTopicSubscription()
com.swiftmq.swiftlet.queue.QueuePushTransaction	getTransaction()
boolean	isPersistentMessageIncluded()
protected void	prepare(com.swiftmq.jms.XidImpl globalTxId)
protected void	publish(com.swiftmq.jms.MessageImpl message)
protected void	rollback()
protected void	rollback(com.swiftmq.jms.XidImpl globalTxId)
protected void	rollback(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)
void	setPersistentMessageIncluded(boolean persistentMessageIncluded)
String	toString()

Methods inherited from class Object

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

Constructor Details

TopicSubscriberTransaction

protected TopicSubscriberTransaction(TopicSubscription topicSubscription,
 com.swiftmq.swiftlet.queue.QueuePushTransaction transaction,
 String destination)

Method Details

isPersistentMessageIncluded

public boolean isPersistentMessageIncluded()

setPersistentMessageIncluded

public void setPersistentMessageIncluded(boolean persistentMessageIncluded)

getTopicSubscription

protected TopicSubscription getTopicSubscription()

getTransaction

public com.swiftmq.swiftlet.queue.QueuePushTransaction getTransaction()

publish

protected void publish(com.swiftmq.jms.MessageImpl message)
                throws Exception

Throws:

Exception

prepare

protected void prepare(com.swiftmq.jms.XidImpl globalTxId)
                throws Exception

Throws:

Exception

commit

protected long commit(com.swiftmq.jms.XidImpl globalTxId)
               throws Exception

Throws:

Exception

commit

protected long commit()
               throws Exception

Throws:

Exception

commit

protected void commit(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

rollback

protected void rollback(com.swiftmq.jms.XidImpl globalTxId)
                 throws Exception

Throws:

Exception

rollback

protected void rollback()
                 throws Exception

Throws:

Exception

rollback

protected void rollback(com.swiftmq.tools.concurrent.AsyncCompletionCallback callback)

toString

public String toString()

Overrides:

toString in class Object