public class TwoPhaseCommitEventProcessor extends Object implements IEventProcessor, ISharedObjectContainerTransaction
| Constructor and Description |
|---|
TwoPhaseCommitEventProcessor(BaseSharedObject bse,
ISharedObjectTransactionConfig config) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addFailed(ID remote,
Throwable failure) |
protected void |
addParticipants(ID[] ids) |
protected void |
doTMAbort(Throwable except) |
protected void |
doTMCommit() |
protected ISharedObjectContext |
getContext() |
protected ID |
getHomeID() |
protected int |
getMinFailedToAbort() |
protected BaseSharedObject |
getSharedObject() |
protected int |
getTimeout() |
byte |
getTransactionState()
Get state of transaction.
|
protected void |
handleActivated(ISharedObjectActivatedEvent event) |
protected void |
handleCreateResponse(ISharedObjectCreateResponseEvent event) |
protected void |
handleDeparted(IContainerDisconnectedEvent event) |
protected void |
handleJoined(IContainerConnectedEvent event) |
protected void |
handlePostCommitFailure(ID fromID,
Throwable e,
long identifier1) |
protected void |
handlePrimaryActivated(ISharedObjectActivatedEvent event) |
protected void |
handleReplicaActivated(ISharedObjectActivatedEvent event) |
protected void |
handleVotingCompletedCreateResponse(ID fromID,
Throwable e,
long identifier1) |
protected boolean |
isPrimary() |
protected boolean |
isVotingCompleted() |
protected void |
localCommitted() |
boolean |
processEvent(Event event)
Process given Event
|
protected void |
removeParticipant(ID id) |
protected void |
replicateTo(ID[] remotes) |
protected void |
sendCommit() |
protected void |
setTransactionState(byte state) |
protected void |
trace(String msg) |
protected void |
traceStack(String msg,
Throwable t) |
void |
waitToCommit()
Method called to wait for a transaction to complete.
|
public TwoPhaseCommitEventProcessor(BaseSharedObject bse, ISharedObjectTransactionConfig config)
protected void trace(String msg)
protected int getTimeout()
protected int getMinFailedToAbort()
protected boolean isPrimary()
protected BaseSharedObject getSharedObject()
protected ID getHomeID()
protected void addParticipants(ID[] ids)
protected void removeParticipant(ID id)
protected ISharedObjectContext getContext()
public boolean processEvent(Event event)
IEventProcessorprocessEvent in interface IEventProcessorevent - the Event to processprotected void handleActivated(ISharedObjectActivatedEvent event)
protected void replicateTo(ID[] remotes)
protected void handlePrimaryActivated(ISharedObjectActivatedEvent event)
protected void handleReplicaActivated(ISharedObjectActivatedEvent event)
protected void handleJoined(IContainerConnectedEvent event)
protected void handleCreateResponse(ISharedObjectCreateResponseEvent event)
protected void handleDeparted(IContainerDisconnectedEvent event)
protected void handleVotingCompletedCreateResponse(ID fromID, Throwable e, long identifier1)
protected void handlePostCommitFailure(ID fromID, Throwable e, long identifier1)
protected void sendCommit()
throws SharedObjectAddAbortException
SharedObjectAddAbortExceptionpublic byte getTransactionState()
ISharedObjectContainerTransactiongetTransactionState in interface ISharedObjectContainerTransactionprotected void setTransactionState(byte state)
public void waitToCommit()
throws SharedObjectAddAbortException
ISharedObjectContainerTransactionwaitToCommit in interface ISharedObjectContainerTransactionSharedObjectAddAbortExceptionprotected void doTMAbort(Throwable except) throws SharedObjectAddAbortException
SharedObjectAddAbortExceptionprotected void doTMCommit()
throws SharedObjectAddAbortException
SharedObjectAddAbortExceptionprotected void localCommitted()
protected boolean isVotingCompleted()
throws SharedObjectAddAbortException
SharedObjectAddAbortExceptionCopyright © 2004–2020 Eclipse Foundation. All rights reserved.