OpflowRpcAmqpRequest (opflow-core 0.3.0 API)

java.lang.Object

com.devebot.opflow.OpflowRpcAmqpRequest

All Implemented Interfaces:: OpflowTimeout.Timeoutable, Iterator

public class OpflowRpcAmqpRequest
extends Object
implements Iterator, OpflowTimeout.Timeoutable

Author:: drupalex

Constructor Summary

Constructors
Constructor	Description
`OpflowRpcAmqpRequest(OpflowRpcParameter params, OpflowTimeout.Listener completeListener)`
`OpflowRpcAmqpRequest(Map<String,Object> options, OpflowTimeout.Listener completeListener)`

Method Summary

Modifier and Type	Method	Description
`OpflowRpcAmqpResult`	`extractResult()`
`OpflowRpcAmqpResult`	`extractResult(boolean includeProgress)`
`String`	`getRoutineId()`
`String`	`getRoutineSignature()`
`String`	`getRoutineTimestamp()`
`long`	`getTimeout()`
`long`	`getTimestamp()`
`boolean`	`hasNext()`
`List<OpflowEngine.Message>`	`iterateResult()`
`OpflowEngine.Message`	`next()`
`void`	`push(OpflowEngine.Message 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 Details
- OpflowRpcAmqpRequest
  
  public OpflowRpcAmqpRequest(OpflowRpcParameter params, OpflowTimeout.Listener completeListener)
- OpflowRpcAmqpRequest
  
  public OpflowRpcAmqpRequest(Map<String,Object> options, OpflowTimeout.Listener completeListener)
Method Details
- getRoutineId
  
  public String getRoutineId()
- getRoutineTimestamp
  
  public String getRoutineTimestamp()
- getRoutineSignature
  
  public String getRoutineSignature()
- 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 OpflowEngine.Message next()
  
  Specified by:
  
  next in interface Iterator
- push
  
  public void push(OpflowEngine.Message message)
- iterateResult
  
  public List<OpflowEngine.Message> iterateResult()
- extractResult
  
  public OpflowRpcAmqpResult extractResult()
- extractResult
  
  public OpflowRpcAmqpResult extractResult(boolean includeProgress)