Package 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	Description
static class	OpflowUtil.OmitInternalOplogs

Constructor Summary

Constructors

Constructor	Description
OpflowUtil()

Method Summary

Modifier and Type	Method	Description
static void	copyParameters(Map<String,Object> target, Map<String,Object> source, String[] keys)
static void	copyParameters(Map<String,Object> target, Map<String,Object> source, String[] keys, boolean overridden)
static Integer	detectFreePort(Map<String,Object> kwargs, String fieldName, Integer[] defaultPorts)
static void	exit(Throwable t)
static boolean	exitOnError()
static String	extractClassName(Class clazz)
static <T> T	extractMethodAnnotation(Method method, Class<? extends Annotation> clazz)
static List<Class<?>>	getAllAncestorTypes(Class<?> clazz)
static String	getAMQPEntrypointCode(Map<String,Object> cfg)
static String	getAMQPEntrypointCode(Map<String,Object> cfg, String exchangeName, String routingKey)
static Boolean	getBooleanField(Map<String,Object> options, String fieldName, Boolean defValue)
static Boolean	getBooleanField(Map<String,Object> options, String fieldName, String[] otherNames, Boolean defValue, boolean assigned)
static byte[]	getBytes(String data)
static Map<String,Object>	getChildMap(Map<String,Object> kwargs, String fieldName)
static Map<String,Object>	getChildMap(Map<String,Object> kwargs, String... fieldNames)
static String	getClassSimpleName(Class clazz)
static String	getDateField(Map<String,Object> headers, String fieldName, boolean currentIfNotFound)
static Integer	getIntegerField(Map<String,Object> options, String fieldName, Integer defValue)
static Integer	getIntegerField(Map<String,Object> options, String fieldName, String[] otherNames, Integer defValue, boolean assigned)
static Long	getLongField(Map<String,Object> options, String fieldName, Long defValue)
static Long	getLongField(Map<String,Object> options, String fieldName, String[] otherNames, Long defValue, boolean assigned)
static String	getMethodSignature(Class clazz, String methodName, Class... args)
static String	getMethodSignature(Method method)
static Object	getOptionField(Map<String,Object> options, String fieldName, Object defval)
static Boolean	getProgressEnabled(Map<String,Object> headers)
static URL	getResource(String location)
static String	getRoutineId(Map<String,Object> headers)
static String	getRoutineId(Map<String,Object> headers, boolean uuidIfNotFound)
static String	getRoutineScope(Map<String,Object> headers)
static String	getRoutineSignature(Map<String,Object> headers)
static String	getRoutineSignature(Map<String,Object> headers, boolean uuidIfNotFound)
static String[]	getRoutineTags(Map<String,Object> headers)
static String[]	getRoutineTags(Map<String,Object> headers, String headerName)
static String	getRoutineTimestamp(Map<String,Object> headers)
static String	getRoutineTimestamp(Map<String,Object> headers, boolean currentIfNotFound)
static String	getString(byte[] data)
static String[]	getStringArray(Map<String,Object> options, String fieldName, String[] defArray)
static String	getStringField(Map<String,Object> options, String fieldName)
static String	getStringField(Map<String,Object> options, String fieldName, boolean uuidIfNotFound)
static String	getStringField(Map<String,Object> options, String fieldName, boolean uuidIfNotFound, boolean assigned)
static String	getStringField(Map<String,Object> options, String fieldName, String defValue)
static String	getStringField(Map<String,Object> options, String fieldName, String[] otherNames)
static String	getStringField(Map<String,Object> options, String fieldName, String[] otherNames, String defValue, boolean uuidIfNotFound, boolean assigned)
static String	getStringField(Map<String,Object> options, String fieldName, String defValue, boolean uuidIfNotFound, boolean assigned)
static String	hidePasswordInUri(String uri)
static boolean	isAMQPEntrypointNull(Map<String,Object> cfg)
static boolean	isAMQPEntrypointNull(Map<String,Object> cfg, String exchangeName, String routingKey)
static boolean	isComponentEnabled(Map<String,Object> cfg)
static boolean	isComponentExplicitEnabled(Map<String,Object> cfg)
static boolean	isComponentImplicitEnabled(Map<String,Object> cfg)
static boolean	isGenericDeclaration(String signature)
static String	maskPassword(String password)
static Throwable	rebuildInvokerException(Map<String,Object> errorMap)
static void	setProgressEnabled(Map<String,Object> headers, Boolean value)
static void	setRoutineId(Map<String,Object> headers, String value)
static void	setRoutineScope(Map<String,Object> headers, String value)
static void	setRoutineSignature(Map<String,Object> headers, String value)
static void	setRoutineTags(Map<String,Object> headers, String[] tags)
static void	setRoutineTimestamp(Map<String,Object> headers, String value)
static void	setStringField(Map<String,Object> options, String fieldName, String value)
static void	sleep(long duration)
static String	truncate(String source)
static String	truncate(String source, int limit)

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowUtil

public OpflowUtil()

Method Details

getBytes

public static byte[] getBytes(String data)

getString

public static String getString(byte[] data)

truncate

public static String truncate(String source)

truncate

public static String truncate(String source, int limit)

copyParameters

public static void copyParameters(Map<String,Object> target, Map<String,Object> source, String[] keys)

copyParameters

public static void copyParameters(Map<String,Object> target, Map<String,Object> source, String[] keys, boolean overridden)

getRoutineId

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

getRoutineId

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

setRoutineId

public static void setRoutineId(Map<String,Object> headers, String value)

getRoutineTimestamp

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

getRoutineTimestamp

public static String getRoutineTimestamp(Map<String,Object> headers, boolean currentIfNotFound)

setRoutineTimestamp

public static void setRoutineTimestamp(Map<String,Object> headers, String value)

getRoutineSignature

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

getRoutineSignature

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

setRoutineSignature

public static void setRoutineSignature(Map<String,Object> headers, String value)

getRoutineScope

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

setRoutineScope

public static void setRoutineScope(Map<String,Object> headers, String value)

getRoutineTags

public static String[] getRoutineTags(Map<String,Object> headers)

getRoutineTags

public static String[] getRoutineTags(Map<String,Object> headers, String headerName)

setRoutineTags

public static void setRoutineTags(Map<String,Object> headers, String[] tags)

getProgressEnabled

public static Boolean getProgressEnabled(Map<String,Object> headers)

setProgressEnabled

public static void setProgressEnabled(Map<String,Object> headers, Boolean value)

getDateField

public static String getDateField(Map<String,Object> headers, String fieldName, boolean currentIfNotFound)

getStringField

public static String getStringField(Map<String,Object> options, String fieldName)

getStringField

public static String getStringField(Map<String,Object> options, String fieldName, String[] otherNames)

getStringField

public static String getStringField(Map<String,Object> options, String fieldName, String defValue)

getStringField

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

getStringField

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

getStringField

public static String getStringField(Map<String,Object> options, String fieldName, String defValue, boolean uuidIfNotFound, boolean assigned)

getStringField

public static String getStringField(Map<String,Object> options, String fieldName, String[] otherNames, String defValue, boolean uuidIfNotFound, boolean assigned)

setStringField

public static void setStringField(Map<String,Object> options, String fieldName, String value)

getStringArray

public static String[] getStringArray(Map<String,Object> options, String fieldName, String[] defArray)

getBooleanField

public static Boolean getBooleanField(Map<String,Object> options, String fieldName, Boolean defValue)

getBooleanField

public static Boolean getBooleanField(Map<String,Object> options, String fieldName, String[] otherNames, Boolean defValue, boolean assigned)

getIntegerField

public static Integer getIntegerField(Map<String,Object> options, String fieldName, Integer defValue)

getIntegerField

public static Integer getIntegerField(Map<String,Object> options, String fieldName, String[] otherNames, Integer defValue, boolean assigned)

getLongField

public static Long getLongField(Map<String,Object> options, String fieldName, Long defValue)

getLongField

public static Long getLongField(Map<String,Object> options, String fieldName, String[] otherNames, Long defValue, boolean assigned)

getOptionField

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

getChildMap

public static Map<String,Object> getChildMap(Map<String,Object> kwargs, String fieldName)

getChildMap

public static Map<String,Object> getChildMap(Map<String,Object> kwargs, String... fieldNames)

detectFreePort

public static Integer detectFreePort(Map<String,Object> kwargs, String fieldName, Integer[] defaultPorts)

getResource

public static URL getResource(String location)

isGenericDeclaration

public static boolean isGenericDeclaration(String signature)

getAllAncestorTypes

public static List<Class<?>> getAllAncestorTypes(Class<?> clazz)

getMethodSignature

public static String getMethodSignature(Class clazz, String methodName, Class... args)

getMethodSignature

public static String getMethodSignature(Method method)

extractMethodAnnotation

public static <T> T extractMethodAnnotation(Method method, Class<? extends Annotation> clazz)

maskPassword

public static String maskPassword(String password)

hidePasswordInUri

public static String hidePasswordInUri(String uri)

isComponentEnabled

public static boolean isComponentEnabled(Map<String,Object> cfg)

isComponentImplicitEnabled

public static boolean isComponentImplicitEnabled(Map<String,Object> cfg)

isComponentExplicitEnabled

public static boolean isComponentExplicitEnabled(Map<String,Object> cfg)

isAMQPEntrypointNull

public static boolean isAMQPEntrypointNull(Map<String,Object> cfg)

isAMQPEntrypointNull

public static boolean isAMQPEntrypointNull(Map<String,Object> cfg, String exchangeName, String routingKey)

getAMQPEntrypointCode

public static String getAMQPEntrypointCode(Map<String,Object> cfg)

getAMQPEntrypointCode

public static String getAMQPEntrypointCode(Map<String,Object> cfg, String exchangeName, String routingKey)

getClassSimpleName

public static String getClassSimpleName(Class clazz)

extractClassName

public static String extractClassName(Class clazz)

rebuildInvokerException

public static Throwable rebuildInvokerException(Map<String,Object> errorMap)

sleep

public static void sleep(long duration)

exitOnError

public static boolean exitOnError()

exit

public static void exit(Throwable t)