public class JMSContinuation extends Object implements Continuation
Constructor and Description |
---|
JMSContinuation(Bus b,
Message m,
MessageObserver observer,
Counter suspendendContinuations) |
Modifier and Type | Method and Description |
---|---|
protected void |
cancelTimerTask() |
protected void |
createTimerTask(long timeout) |
protected void |
doResume() |
Object |
getObject()
Get arbitrary object associated with the continuation for context
|
boolean |
isNew()
Is this a newly created Continuation.
|
boolean |
isPending()
Get the pending status
|
boolean |
isResumed()
Get the resumed status
|
void |
reset()
Reset the continuation
|
void |
resume()
Resume a suspended request
|
void |
setObject(Object o)
Sets arbitrary object associated with the continuation for context
|
boolean |
suspend(long timeout)
This method will suspend the request for the timeout or until resume is
called
|
public JMSContinuation(Bus b, Message m, MessageObserver observer, Counter suspendendContinuations)
public Object getObject()
Continuation
getObject
in interface Continuation
public boolean isNew()
Continuation
isNew
in interface Continuation
public boolean isPending()
Continuation
isPending
in interface Continuation
public boolean isResumed()
Continuation
isResumed
in interface Continuation
public void reset()
Continuation
reset
in interface Continuation
public void resume()
Continuation
resume
in interface Continuation
protected void doResume()
public void setObject(Object o)
Continuation
setObject
in interface Continuation
o
- An arbitrary object to associate with the continuationpublic boolean suspend(long timeout)
Continuation
suspend
in interface Continuation
timeout
- A timeout of < 0 will cause an immediate return.
A timeout of 0 will wait indefinitely.protected void createTimerTask(long timeout)
protected void cancelTimerTask()
Apache CXF