Package energy.eddie.api.agnostic.outbound

Interface RawDataOutboundConnector

All Known Implementing Classes:

AgnosticConnector, AmqpOutbound, KafkaConnector

public interface RawDataOutboundConnector

Gets a raw data stream and emits the raw data messages to the eligible party.

Method Summary

Modifier and Type	Method	Description
void	setRawDataStream(reactor.core.publisher.Flux<RawDataMessage> rawDataStream)	Sets a Flux that can be subscribed to, to emit raw data messages to the eligible party.

Method Details

setRawDataStream

void setRawDataStream(reactor.core.publisher.Flux<RawDataMessage> rawDataStream)

Sets a Flux that can be subscribed to, to emit raw data messages to the eligible party.

Parameters:

rawDataStream - flux containing raw data messages