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 workerTag, 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	getReplyQueueName()
String	getRequestId()
String	getWorkerTag()

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 workerTag, String replyQueueName)

Method Details

getApplicationId

public String getApplicationId()

getRequestId

public String getRequestId()

getReplyQueueName

public String getReplyQueueName()

getWorkerTag

public String getWorkerTag()

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)