Package com.devebot.opflow

Class OpflowRpcResponse

java.lang.Object

com.devebot.opflow.OpflowRpcResponse

public class OpflowRpcResponse
extends Object

Author:

drupalex

Constructor Summary

Constructors

Constructor	Description
OpflowRpcResponse(com.rabbitmq.client.Channel channel, com.rabbitmq.client.AMQP.BasicProperties properties, String consumerTag, String replyQueueName)

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	getRequestId()

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowRpcResponse

public OpflowRpcResponse(com.rabbitmq.client.Channel channel, com.rabbitmq.client.AMQP.BasicProperties properties, String consumerTag, String replyQueueName)

Method Details

getApplicationId

public String getApplicationId()

getRequestId

public String getRequestId()

getReplyQueueName

public String getReplyQueueName()

getConsumerTag

public String getConsumerTag()

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)