View Source GenericExecutor behaviour (reactive_commons v1.0.2)

Implements generic behaviour for message executors

Summary

parsed_payload()

decode(t)

Decode message payload from MessageToHandle.

Extract handler function path (name) from the message.

It's called when handler return (optional).

@type handler_response() :: any()

@type parsed_payload() :: map()

@callback decode(MessageToHandle.t()) :: parsed_payload()

Decode message payload from MessageToHandle.

@callback get_handler_path(MessageToHandle.t(), parsed_payload()) :: String.t()

Extract handler function path (name) from the message.

@callback on_post_process(handler_response(), MessageToHandle.t()) :: any()