Apache CXF API

org.apache.cxf.transport.jms.continuations
Class JMSContinuation

java.lang.Object
  extended by org.apache.cxf.transport.jms.continuations.JMSContinuation
All Implemented Interfaces:
Continuation

public class JMSContinuation
extends Object
implements Continuation


Constructor Summary
JMSContinuation(Bus b, Message m, MessageObserver observer, Collection<JMSContinuation> cList, org.springframework.jms.listener.AbstractMessageListenerContainer jmsListener, JMSConfiguration jmsConfig)
           
 
Method Summary
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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSContinuation

public JMSContinuation(Bus b,
                       Message m,
                       MessageObserver observer,
                       Collection<JMSContinuation> cList,
                       org.springframework.jms.listener.AbstractMessageListenerContainer jmsListener,
                       JMSConfiguration jmsConfig)
Method Detail

getObject

public Object getObject()
Description copied from interface: Continuation
Get arbitrary object associated with the continuation for context

Specified by:
getObject in interface Continuation
Returns:
An arbitrary object associated with the continuation

isNew

public boolean isNew()
Description copied from interface: Continuation
Is this a newly created Continuation.

Specified by:
isNew in interface Continuation
Returns:
True if the continuation has just been created and has not yet suspended the request.

isPending

public boolean isPending()
Description copied from interface: Continuation
Get the pending status

Specified by:
isPending in interface Continuation
Returns:
True if the continuation has been suspended.

isResumed

public boolean isResumed()
Description copied from interface: Continuation
Get the resumed status

Specified by:
isResumed in interface Continuation
Returns:
True if the continuation is has been resumed.

reset

public void reset()
Description copied from interface: Continuation
Reset the continuation

Specified by:
reset in interface Continuation

resume

public void resume()
Description copied from interface: Continuation
Resume a suspended request

Specified by:
resume in interface Continuation

doResume

protected void doResume()

setObject

public void setObject(Object o)
Description copied from interface: Continuation
Sets arbitrary object associated with the continuation for context

Specified by:
setObject in interface Continuation
Parameters:
o - An arbitrary object to associate with the continuation

suspend

public boolean suspend(long timeout)
Description copied from interface: Continuation
This method will suspend the request for the timeout or until resume is called

Specified by:
suspend in interface Continuation
Parameters:
timeout - A timeout of < 0 will cause an immediate return. A timeout of 0 will wait indefinitely.
Returns:
True if resume called or false if timeout.

createTimerTask

protected void createTimerTask(long timeout)

cancelTimerTask

protected void cancelTimerTask()

updateContinuations

protected void updateContinuations(boolean remove)

modifyList

protected void modifyList(boolean remove)

Apache CXF API

Apache CXF