OutputMessageRouter
class OutputMessageRouter(recordsDataChannelMedium: DataChannelMedium, recordsDataChannelFormat: DataChannelFormat, standardOutputConsumer: StandardOutputConsumer, additionalProperties: Map<String, String>, feedBootstrap: FeedBootstrap<*>, acquiredResources: Map<ResourceType, Resource.Acquired>) : AutoCloseable
OutputMessageRouter is responsible for building the appropriate routes for messages output. Record message stream state and status traces may go over std output, or over sockets in JSONL or Protobuf format. All other message like log or error messages go over std output.
Constructors
Link copied to clipboard
constructor(recordsDataChannelMedium: DataChannelMedium, recordsDataChannelFormat: DataChannelFormat, standardOutputConsumer: StandardOutputConsumer, additionalProperties: Map<String, String>, feedBootstrap: FeedBootstrap<*>, acquiredResources: Map<ResourceType, Resource.Acquired>)
Properties
Link copied to clipboard
var recordAcceptors: Map<StreamIdentifier, (NativeRecordPayload, Map<Field, FieldValueChange>?) -> Unit>