com.devebot.opflow.OpflowRpcAmqpResponse

public class OpflowRpcAmqpResponse
extends Object

Constructor Summary

Constructors
Constructor	Description
`OpflowRpcAmqpResponse(com.rabbitmq.nostro.client.Channel channel, com.rabbitmq.nostro.client.AMQP.BasicProperties properties, String componentId, String consumerTag, String replyQueueName, String routineId, String routineTimestamp, String routineScope, String routineSignature, String httpAddress)`

Method Summary

Modifier and Type	Method	Description
`void`	`emitCompleted(byte[] result)`
`void`	`emitCompleted(String result)`
`void`	`emitFailed(byte[] error)`
`void`	`emitFailed(String error)`
`void`	`emitProgress(int completed, int total)`
`void`	`emitProgress(int completed, int total, String jsonData)`
`void`	`emitStarted()`
`void`	`emitStarted(byte[] info)`
`void`	`emitStarted(String content)`
`String`	`getApplicationId()`
`String`	`getConsumerTag()`
`String`	`getReplyQueueName()`
`String`	`getRoutineId()`
`String`	`getRoutineScope()`
`String`	`getRoutineSignature()`
`String`	`getRoutineTimestamp()`

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

Constructor Details
- OpflowRpcAmqpResponse
  
  public OpflowRpcAmqpResponse(com.rabbitmq.nostro.client.Channel channel, com.rabbitmq.nostro.client.AMQP.BasicProperties properties, String componentId, String consumerTag, String replyQueueName, String routineId, String routineTimestamp, String routineScope, String routineSignature, String httpAddress)
Method Details
- getApplicationId
  
  public String getApplicationId()
- getReplyQueueName
  
  public String getReplyQueueName()
- getConsumerTag
  
  public String getConsumerTag()
- getRoutineId
  
  public String getRoutineId()
- getRoutineTimestamp
  
  public String getRoutineTimestamp()
- getRoutineScope
  
  public String getRoutineScope()
- getRoutineSignature
  
  public String getRoutineSignature()
- emitStarted
  
  public void emitStarted()
- emitStarted
  
  public void emitStarted(String content)
- emitStarted
  
  public void emitStarted(byte[] info)
- emitProgress
  
  public void emitProgress(int completed, int total)
- emitProgress
  
  public void emitProgress(int completed, int total, String jsonData)
- emitFailed
  
  public void emitFailed(String error)
- emitFailed
  
  public void emitFailed(byte[] error)
- emitCompleted
  
  public void emitCompleted(String result)
- emitCompleted
  
  public void emitCompleted(byte[] result)