public class JMSContinuation extends Object implements Continuation
| Constructor and Description |
|---|
JMSContinuation(Bus b,
Message m,
MessageObserver observer,
Collection<JMSContinuation> cList,
org.springframework.jms.listener.AbstractMessageListenerContainer jmsListener,
JMSConfiguration jmsConfig) |
| 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
|
protected void |
modifyList(boolean remove) |
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
|
protected void |
updateContinuations(boolean remove) |
public JMSContinuation(Bus b, Message m, MessageObserver observer, Collection<JMSContinuation> cList, org.springframework.jms.listener.AbstractMessageListenerContainer jmsListener, JMSConfiguration jmsConfig)
public Object getObject()
ContinuationgetObject in interface Continuationpublic boolean isNew()
ContinuationisNew in interface Continuationpublic boolean isPending()
ContinuationisPending in interface Continuationpublic boolean isResumed()
ContinuationisResumed in interface Continuationpublic void reset()
Continuationreset in interface Continuationpublic void resume()
Continuationresume in interface Continuationprotected void doResume()
public void setObject(Object o)
ContinuationsetObject in interface Continuationo - An arbitrary object to associate with the continuationpublic boolean suspend(long timeout)
Continuationsuspend in interface Continuationtimeout - A timeout of < 0 will cause an immediate return.
A timeout of 0 will wait indefinitely.protected void createTimerTask(long timeout)
protected void cancelTimerTask()
protected void updateContinuations(boolean remove)
protected void modifyList(boolean remove)
Apache CXF