com.devebot.opflow.OpflowRpcRequest

public class OpflowRpcRequest
extends Object
implements Iterator, OpflowTimeout.Timeoutable

Method Summary

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

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

forEachRemaining, remove

Constructor Details
- OpflowRpcRequest
  
  public OpflowRpcRequest(Map<String,Object> options, OpflowTimeout.Listener completeListener)
Method Details
- getRequestId
  
  public String getRequestId()
- getRequestTime
  
  public String getRequestTime()
- getRoutineId
  
  public String getRoutineId()
- getTimeout
  
  public long getTimeout()
  
  Specified by:
  
  getTimeout in interface OpflowTimeout.Timeoutable
- getTimestamp
  
  public long getTimestamp()
  
  Specified by:
  
  getTimestamp in interface OpflowTimeout.Timeoutable
- raiseTimeout
  
  public void raiseTimeout()
  
  Specified by:
  
  raiseTimeout in interface OpflowTimeout.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)

Class OpflowRpcRequest