services.moleculer.util

Class CommonUtils

java.lang.Object

services.moleculer.util.CommonUtils

public final class CommonUtils
extends java.lang.Object

Common utilities.

Constructor Summary

Constructors

Constructor and Description
CommonUtils()

Method Summary

Modifier and Type	Method and Description
static byte[]	compress(byte[] data, int level)
static void	convertAnnotations(io.datatree.Tree config, java.lang.annotation.Annotation[] annotations)
static byte[]	decompress(byte[] data)
static ParseResult	extractStream(io.datatree.Tree data)
static java.lang.String	formatNamoSec(long nanoSec)
static java.lang.String	formatNumber(java.lang.Number number)
static java.lang.String	formatPath(java.lang.String path)
static java.lang.Object	getFieldFromProxy(java.lang.Object object, java.lang.reflect.Field field)
static java.lang.String	getFormat(java.lang.String path)
static java.lang.String	getHostName()
static java.lang.String	getHostOrIP(boolean preferHostname, io.datatree.Tree info)
static io.datatree.Tree	getNodeInfos(ServiceBroker broker, Transporter transporter)
static io.datatree.Tree	mergeMeta(io.datatree.Tree rsp, io.datatree.Tree req)
static java.lang.String	nameOf(java.lang.Class<?> type, boolean addQuotes)
static java.lang.String	nameOf(java.lang.Object object, boolean addQuotes)
static java.lang.String	nameOf(java.lang.String prefix, java.lang.reflect.Field field)
static ParseResult	parseParams(java.lang.Object[] params)
static java.lang.String[]	parseURLs(io.datatree.Tree config, java.lang.String name, java.lang.String[] defaultURLs)
static byte[]	readFully(java.io.InputStream in)
static io.datatree.Tree	readTree(java.io.InputStream in, java.lang.String format)
static io.datatree.Tree	readTree(java.lang.String resourceURL)
static io.datatree.Tree	removeLocalEvents(io.datatree.Tree descriptor)
static long	resolveUnit(java.lang.String string)
static void	suggestDependency(java.lang.String groupId, java.lang.String artifactId, java.lang.String version)
static FastBuildTree	throwableToTree(java.lang.String id, java.lang.String nodeID, java.lang.String protocolVersion, java.lang.Throwable error)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommonUtils

public CommonUtils()

Method Detail

mergeMeta

public static final io.datatree.Tree mergeMeta(io.datatree.Tree rsp,
                                               io.datatree.Tree req)

getFieldFromProxy

public static final java.lang.Object getFieldFromProxy(java.lang.Object object,
                                                       java.lang.reflect.Field field)
                                                throws java.lang.Exception

Throws:

java.lang.Exception

throwableToTree

public static final FastBuildTree throwableToTree(java.lang.String id,
                                                  java.lang.String nodeID,
                                                  java.lang.String protocolVersion,
                                                  java.lang.Throwable error)

formatPath

public static final java.lang.String formatPath(java.lang.String path)

suggestDependency

public static final void suggestDependency(java.lang.String groupId,
                                           java.lang.String artifactId,
                                           java.lang.String version)

convertAnnotations

public static final void convertAnnotations(io.datatree.Tree config,
                                            java.lang.annotation.Annotation[] annotations)
                                     throws java.lang.IllegalAccessException,
                                            java.lang.IllegalArgumentException,
                                            java.lang.reflect.InvocationTargetException

Throws:

java.lang.IllegalAccessException

java.lang.IllegalArgumentException

java.lang.reflect.InvocationTargetException

formatNumber

public static final java.lang.String formatNumber(java.lang.Number number)

formatNamoSec

public static final java.lang.String formatNamoSec(long nanoSec)

getNodeInfos

public static final io.datatree.Tree getNodeInfos(ServiceBroker broker,
                                                  Transporter transporter)

removeLocalEvents

public static final io.datatree.Tree removeLocalEvents(io.datatree.Tree descriptor)

getHostOrIP

public static final java.lang.String getHostOrIP(boolean preferHostname,
                                                 io.datatree.Tree info)

getHostName

public static final java.lang.String getHostName()

parseURLs

public static final java.lang.String[] parseURLs(io.datatree.Tree config,
                                                 java.lang.String name,
                                                 java.lang.String[] defaultURLs)

extractStream

public static final ParseResult extractStream(io.datatree.Tree data)

parseParams

public static final ParseResult parseParams(java.lang.Object[] params)

nameOf

public static final java.lang.String nameOf(java.lang.String prefix,
                                            java.lang.reflect.Field field)

nameOf

public static final java.lang.String nameOf(java.lang.Object object,
                                            boolean addQuotes)

nameOf

public static final java.lang.String nameOf(java.lang.Class<?> type,
                                            boolean addQuotes)

readTree

public static final io.datatree.Tree readTree(java.lang.String resourceURL)
                                       throws java.lang.Exception

Throws:

java.lang.Exception

readTree

public static final io.datatree.Tree readTree(java.io.InputStream in,
                                              java.lang.String format)
                                       throws java.lang.Exception

Throws:

java.lang.Exception

readFully

public static final byte[] readFully(java.io.InputStream in)
                              throws java.io.IOException

Throws:

java.io.IOException

getFormat

public static final java.lang.String getFormat(java.lang.String path)

compress

public static final byte[] compress(byte[] data,
                                    int level)
                             throws java.io.IOException

Throws:

java.io.IOException

decompress

public static final byte[] decompress(byte[] data)
                               throws java.io.IOException,
                                      java.util.zip.DataFormatException

Throws:

java.io.IOException

java.util.zip.DataFormatException

resolveUnit

public static final long resolveUnit(java.lang.String string)
                              throws java.lang.NumberFormatException

Throws:

java.lang.NumberFormatException