public class DtxBranch extends Object
Modifier and Type | Class and Description |
---|---|
static class |
DtxBranch.State |
Constructor and Description |
---|
DtxBranch(Transaction.StoredXidRecord storedXidRecord,
MessageStore store,
VirtualHostImpl vhost) |
DtxBranch(Xid xid,
MessageStore store,
VirtualHostImpl vhost) |
Modifier and Type | Method and Description |
---|---|
void |
addPostTransactionAction(ServerTransaction.Action postTransactionAction) |
void |
clearAssociations() |
void |
close() |
void |
commit() |
void |
dequeue(MessageEnqueueRecord record) |
void |
enqueue(TransactionLogResource queue,
EnqueueableMessage message,
Action<MessageEnqueueRecord> enqueueAction) |
boolean |
expired() |
DtxBranch.State |
getState() |
long |
getTimeout() |
Xid |
getXid() |
boolean |
hasAssociatedActiveSessions() |
boolean |
hasAssociatedSessions() |
boolean |
isAssociated(AMQSessionModel session) |
void |
prepare() |
void |
prePrepareTransaction() |
boolean |
resumeSession(AMQSessionModel session) |
void |
rollback() |
void |
setState(DtxBranch.State state) |
void |
setTimeout(long timeout) |
boolean |
suspendSession(AMQSessionModel session) |
public DtxBranch(Xid xid, MessageStore store, VirtualHostImpl vhost)
public DtxBranch(Transaction.StoredXidRecord storedXidRecord, MessageStore store, VirtualHostImpl vhost)
public Xid getXid()
public DtxBranch.State getState()
public void setState(DtxBranch.State state)
public long getTimeout()
public void setTimeout(long timeout)
public boolean expired()
public boolean isAssociated(AMQSessionModel session)
public boolean hasAssociatedSessions()
public boolean hasAssociatedActiveSessions()
public void clearAssociations()
public boolean resumeSession(AMQSessionModel session)
public boolean suspendSession(AMQSessionModel session)
public void prepare() throws StoreException
StoreException
public void rollback() throws StoreException
StoreException
public void commit() throws StoreException
StoreException
public void prePrepareTransaction() throws StoreException
StoreException
public void addPostTransactionAction(ServerTransaction.Action postTransactionAction)
public void dequeue(MessageEnqueueRecord record)
public void enqueue(TransactionLogResource queue, EnqueueableMessage message, Action<MessageEnqueueRecord> enqueueAction)
public void close()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.