com.devebot.opflow

Class OpflowRpcRequest

java.lang.Object

com.devebot.opflow.OpflowRpcRequest

All Implemented Interfaces:

OpflowTask.Timeoutable, Iterator

public class OpflowRpcRequest
extends Object
implements Iterator, OpflowTask.Timeoutable

Author:

drupalex

Constructor Summary

Constructors

Constructor and Description
OpflowRpcRequest(Map<String,Object> options, OpflowTask.Listener completeListener)

Method Summary

Modifier and Type	Method and Description
OpflowRpcResult	extractResult()
OpflowRpcResult	extractResult(boolean includeProgress)
String	getRequestId()
String	getRoutineId()
static String	getStatus(OpflowMessage message)
long	getTimeout()
long	getTimestamp()
boolean	hasNext()
List<OpflowMessage>	iterateResult()
OpflowMessage	next()
void	push(OpflowMessage message)
void	raiseTimeout()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

OpflowRpcRequest

public OpflowRpcRequest(Map<String,Object> options,
                        OpflowTask.Listener completeListener)

Method Detail

getRequestId

public String getRequestId()

getRoutineId

public String getRoutineId()

getTimeout

public long getTimeout()

Specified by:

getTimeout in interface OpflowTask.Timeoutable

getTimestamp

public long getTimestamp()

Specified by:

getTimestamp in interface OpflowTask.Timeoutable

raiseTimeout

public void raiseTimeout()

Specified by:

raiseTimeout in interface OpflowTask.Timeoutable

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator

next

public OpflowMessage next()

Specified by:

next in interface Iterator

push

public void push(OpflowMessage message)

iterateResult

public List<OpflowMessage> iterateResult()

extractResult

public OpflowRpcResult extractResult()

extractResult

public OpflowRpcResult extractResult(boolean includeProgress)

getStatus

public static String getStatus(OpflowMessage message)