Get event body @return original or restored event body

Optionally set a parameter @param key of a parameter @param value of a parameter @return event envelope

Retrieve an element from a map using a composite path (Nested array is supported) e.g. "some.key", "some.array[3]", "hello.world[2][10][1]" @param co

Set the target route @param to target route @return event envelope

Set payload @param body Usually a PoJo, a Map or Java primitive @return event envelope

Send an event to a target service in multiple servers @param to target route @param parameters for the event @throws IOException in case of invalid r

Retrieve a header value using case-insensitive key @param key of the header @return header value

Retrieve a parameter value by key with return value enforced as a string @param key of a configuration parameter @return parameter value as a string

Register a private lambda function with one or more concurrent instances. Private function is only visible within a single execution unit. Its routing

Send a ready signal to the manager to fetch the next event.

This method allows your app to send an async or RPC request to another application instance <p> You can retrieve result from the future's onSuccess(Ev

Origin ID is the unique identifier for an application instance. <p> If you call the setAppId(name) method before the event system starts, orig

Obtain the pub/sub cluster handler instance @param clusterName for referring to an event stream cluster @return PubSub handler instance

Pack input into a byte array. @param obj - Map, List or a PoJo Object that contains get/set methods for variables @return packed byte array @throws

Unpack method for generic map or list object @param bytes - packed structure @return result - Map, List or PoJo object @throws IOException for mappi

Split a string using a set of separators Skips empty values. @param str the input string @param chars the characters to be used as separators @return

Get default object mapper <p> @return object mapper

This method allows your app to send an async or RPC request to another application instance <p> You can retrieve result from the future's onSuccess(Ev

This method returns application name <p> Note: please set the same application name in pom.xml and application.properties @return app name

Serialize the EventEnvelope as a byte array @return byte array @throws IOException in case of encoding errors

Get raw form of event body in Map or Java primitive <p> @return body in map or primitive form

Check if some route names are registered in this application instance @param routes of the services @return true or false

Unregister a route from this application instance @param route name of a service @return true if successful

Load a configuration file into a config reader @param path of the configuration file prefix with "classpath:/" or "file:/" @throws IOException if fil

Optionally set status code (use HTTP compatible response code) if the return object is an event envelope. @param status 200 for normal response @retu

A transaction trace should only be created by the rest-automation application or a service at the "edge". @param traceId unique ID for distributed tr

DeSerialize the EventEnvelope from a byte array @param bytes encoded payload @throws IOException in case of decoding errors

Internal API - This method returns a lambda function executor for running worker in a kernel thread @return executor

Optionally provide the sender @param from the sender @return event envelope

Check if all routes in a list exist @param routes list of service route names @return true or false

Optionally set the replyTo address @param replyTo route @return event envelope

User application may obtain the trace ID of the current transaction @return trace ID of the current transaction

Set request body @param body will be converted to map if it is a PoJo @return this

Internal API - This vertx instance must be used exclusively by the platform-core <p> This is used for running kotlin co-routines in the event loop and

Register a public lambda function with one or more concurrent instances. Its routing path will be published to the global service registry. @param ro

Retrieve a parameter value by key with return value enforced as a string @param key of a configuration parameter @return parameter value as a string

Optionally set a correlation-ID @param cid correlation-ID @return event envelope

This entry point decides the optimal way to start. @param args from command line, if any

User application may obtain the trace path of the current transaction @return trace path of the current transaction