RigOutboundGateway.Kinesis.JavaClient (Reactive Interaction Gateway v3.0.0-alpha.2) View Source
Manages the external Java-based Kinesis client application.
In Java land this would've been named AmazonKinesisJavaClientManager.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Returns module configuration.
Starts (and awaits) the Java-client for Amazon Kinesis.
Link to this section Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Specs
config() :: any()
Returns module configuration.
If application environment contains values in Keyword or Map struct,
defaults from macro usage will be recursively merged with application configuration.
If one of the configuration parameters does not exist or can not be resolved, raises ArgumentError.
Starts (and awaits) the Java-client for Amazon Kinesis.
The process output is discarded. Instead of using stdout to receive Kinesis messages from the Java client, the Java code uses JInterface to RPC RigOutboundGateway.handle_raw/1 directly. This ensures that message boundaries are kept (think newlines in messages) and that console log output doesn't interfere.