com.devebot.opflow

Class OpflowUtil

java.lang.Object

com.devebot.opflow.OpflowUtil

public class OpflowUtil
extends Object

Author:

drupalex

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	OpflowUtil.MapListener

Constructor Summary

Constructors

Constructor and Description
OpflowUtil()

Method Summary

Modifier and Type	Method and Description
static <T> boolean	arrayContains(T[] array, T v)
static String	buildJson(OpflowUtil.MapListener listener)
static Map<String,Object>	buildOptions(OpflowUtil.MapListener listener)
static Map<String,Object>	buildOptions(OpflowUtil.MapListener listener, Map<String,Object> defaultOpts)
static Map<String,Object>	cloneParameters(Map<String,Object> params)
static Map<String,Object>	ensureNotNull(Map<String,Object> opts)
static OpflowRpcResult	exhaustRequest(OpflowRpcRequest request)
static OpflowRpcResult	exhaustRequest(OpflowRpcRequest request, boolean includeProgress)
static byte[]	getBytes(String data)
static long	getCurrentTime()
static Map<String,Object>	getHeaders(com.rabbitmq.client.AMQP.BasicProperties properties)
static String	getMessageField(OpflowMessage message, String fieldName)
static String	getRequestID(Map<String,Object> headers)
static String	getStatus(OpflowMessage message)
static String	getString(byte[] data)
static String	getUUID()
static List<OpflowMessage>	iterateRequest(OpflowRpcRequest request)
static String[]	splitByComma(String source)

Methods inherited from class java.lang.Object

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

Constructor Detail

OpflowUtil

public OpflowUtil()

Method Detail

getCurrentTime

public static long getCurrentTime()

getUUID

public static String getUUID()

getBytes

public static byte[] getBytes(String data)

getString

public static String getString(byte[] data)

cloneParameters

public static Map<String,Object> cloneParameters(Map<String,Object> params)

arrayContains

public static <T> boolean arrayContains(T[] array,
                                        T v)

buildJson

public static String buildJson(OpflowUtil.MapListener listener)

buildOptions

public static Map<String,Object> buildOptions(OpflowUtil.MapListener listener)

buildOptions

public static Map<String,Object> buildOptions(OpflowUtil.MapListener listener,
                                              Map<String,Object> defaultOpts)

ensureNotNull

public static Map<String,Object> ensureNotNull(Map<String,Object> opts)

getHeaders

public static Map<String,Object> getHeaders(com.rabbitmq.client.AMQP.BasicProperties properties)

getRequestID

public static String getRequestID(Map<String,Object> headers)

splitByComma

public static String[] splitByComma(String source)

getMessageField

public static String getMessageField(OpflowMessage message,
                                     String fieldName)

getStatus

public static String getStatus(OpflowMessage message)

iterateRequest

public static List<OpflowMessage> iterateRequest(OpflowRpcRequest request)

exhaustRequest

public static OpflowRpcResult exhaustRequest(OpflowRpcRequest request)

exhaustRequest

public static OpflowRpcResult exhaustRequest(OpflowRpcRequest request,
                                             boolean includeProgress)