public class DtxRegistry extends Object
Constructor and Description |
---|
DtxRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commit(Xid id,
boolean onePhase) |
void |
endAssociations(AMQSessionModel session) |
void |
forget(Xid id) |
DtxBranch |
getBranch(Xid xid) |
long |
getTimeout(Xid id) |
void |
prepare(Xid id) |
List<Xid> |
recover() |
boolean |
registerBranch(DtxBranch branch) |
void |
rollback(Xid id) |
void |
setTimeout(Xid id,
long timeout) |
public boolean registerBranch(DtxBranch branch)
public void commit(Xid id, boolean onePhase) throws IncorrectDtxStateException, UnknownDtxBranchException, StoreException, RollbackOnlyDtxException, TimeoutDtxException
public void prepare(Xid id) throws UnknownDtxBranchException, IncorrectDtxStateException, StoreException, RollbackOnlyDtxException, TimeoutDtxException
public void rollback(Xid id) throws IncorrectDtxStateException, UnknownDtxBranchException, StoreException, TimeoutDtxException
public void forget(Xid id) throws UnknownDtxBranchException, IncorrectDtxStateException
public long getTimeout(Xid id) throws UnknownDtxBranchException
UnknownDtxBranchException
public void setTimeout(Xid id, long timeout) throws UnknownDtxBranchException
UnknownDtxBranchException
public void endAssociations(AMQSessionModel session)
public void close()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.