Package com.tangosol.coherence.servlet
Class ExitObserver
- java.lang.Object
-
- com.tangosol.coherence.servlet.ExitObserver
-
- All Implemented Interfaces:
InvocationObserver
public class ExitObserver extends Object implements InvocationObserver
This InvocationObserver waits for an ExitAgent to report back that some server in the cluster did have the specified session id locked.
-
-
Constructor Summary
Constructors Constructor Description ExitObserver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
invocationCompleted()
This method is called by theInvocationService
to inform the InvocationObserver that all service members have either finished theInvocable
object execution or are not (or no longer) running the InvocationService.boolean
isDone()
Determine if an agent has reported that the session was unlocked.void
memberCompleted(Member member, Object oResult)
This method is called by theInvocationService
to inform the InvocationObserver that a member has finished running theInvocable
object; the result of the invocation, if any, is provided to the InvocationObserver.void
memberFailed(Member member, Throwable eFailure)
This method is called by theInvocationService
to inform the InvocationObserver that a member has thrown an exception while running theInvocable
object.void
memberLeft(Member member)
This method is called by theInvocationService
to inform the InvocationObserver that a member that theInvocable
object was intended for execution upon has left the service (or the cluster).protected void
setDone(boolean fDone)
Toggle the successful completion (session was unlocked) of any one agent.
-
-
-
Method Detail
-
memberCompleted
public void memberCompleted(Member member, Object oResult)
This method is called by theInvocationService
to inform the InvocationObserver that a member has finished running theInvocable
object; the result of the invocation, if any, is provided to the InvocationObserver. The result will be null if no result is registered by the Invocable object, or if it explicitly registers a result whose value is null.- Specified by:
memberCompleted
in interfaceInvocationObserver
- Parameters:
member
- cluster Member that has finished the execution of the Invocable objectoResult
- the result, if any, of the invocation
-
memberFailed
public void memberFailed(Member member, Throwable eFailure)
This method is called by theInvocationService
to inform the InvocationObserver that a member has thrown an exception while running theInvocable
object.- Specified by:
memberFailed
in interfaceInvocationObserver
- Parameters:
member
- cluster Member that encountered an exception while executing the Invocable objecteFailure
- the Throwable object that was encountered
-
memberLeft
public void memberLeft(Member member)
This method is called by theInvocationService
to inform the InvocationObserver that a member that theInvocable
object was intended for execution upon has left the service (or the cluster).It cannot be determined whether the member never received the Invocable object, received and began execution of it and left before finishing, or even completed execution of it without managing to report a result.
- Specified by:
memberLeft
in interfaceInvocationObserver
- Parameters:
member
- cluster Member that left the service before reporting the completion of the execution of the Invocable object
-
invocationCompleted
public void invocationCompleted()
This method is called by theInvocationService
to inform the InvocationObserver that all service members have either finished theInvocable
object execution or are not (or no longer) running the InvocationService.- Specified by:
invocationCompleted
in interfaceInvocationObserver
-
isDone
public boolean isDone()
Determine if an agent has reported that the session was unlocked.- Returns:
- true if an agent has reported that the session was unlocked
-
setDone
protected void setDone(boolean fDone)
Toggle the successful completion (session was unlocked) of any one agent.- Parameters:
fDone
- true if an agent reports that the session was unlocked
-
-