com.devebot.opflow

Class OpflowRpcResponse

java.lang.Object

com.devebot.opflow.OpflowRpcResponse

public class OpflowRpcResponse
extends Object

Author:

drupalex

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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)

Methods inherited from class java.lang.Object

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

Constructor Detail

OpflowRpcResponse

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

Method Detail

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)