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 void	assertTestingEnv()
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 String	getMessageField(OpflowMessage message, String fieldName)
static String	getOptionField(Map<String,Object> options, String fieldName, boolean uuidIfNotFound)
static String	getRequestId(Map<String,Object> headers)
static String	getRequestId(Map<String,Object> headers, boolean uuidIfNotFound)
static String	getRoutineId(Map<String,Object> headers)
static String	getRoutineId(Map<String,Object> headers, boolean uuidIfNotFound)
static String	getStatus(OpflowMessage message)
static String	getString(byte[] data)
static String	getUUID()
static boolean	isTestingEnv()
static List<OpflowMessage>	iterateRequest(OpflowRpcRequest request)
static String	jsonMapToString(Map<String,Object> jsonMap)
static String	jsonObjToString(Object jsonObj)
static Map<String,Object>	jsonStringToMap(String json)
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

jsonObjToString

public static String jsonObjToString(Object jsonObj)

jsonMapToString

public static String jsonMapToString(Map<String,Object> jsonMap)

jsonStringToMap

public static Map<String,Object> jsonStringToMap(String json)

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)

getRequestId

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

getRequestId

public static String getRequestId(Map<String,Object> headers,
                                  boolean uuidIfNotFound)

getRoutineId

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

getRoutineId

public static String getRoutineId(Map<String,Object> headers,
                                  boolean uuidIfNotFound)

getOptionField

public static String getOptionField(Map<String,Object> options,
                                    String fieldName,
                                    boolean uuidIfNotFound)

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)

isTestingEnv

public static boolean isTestingEnv()

assertTestingEnv

public static void assertTestingEnv()