Package energy.eddie.outbound.kafka.agnostic

Class OpaqueEnvelopeKafkaConnector

java.lang.Object

energy.eddie.outbound.kafka.agnostic.OpaqueEnvelopeKafkaConnector

All Implemented Interfaces:

OpaqueEnvelopeOutboundConnector

@Component
public class OpaqueEnvelopeKafkaConnector
extends Object
implements OpaqueEnvelopeOutboundConnector

Constructor Summary

Constructors

Constructor	Description
OpaqueEnvelopeKafkaConnector()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<OpaqueEnvelope>	getOpaqueEnvelopes()	A flux of OpaqueEnvelopes, which provide an opaque envelopes with any payload for a certain time period.
void	process(OpaqueEnvelope payload)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OpaqueEnvelopeKafkaConnector

public OpaqueEnvelopeKafkaConnector()

Method Details

getOpaqueEnvelopes

public reactor.core.publisher.Flux<OpaqueEnvelope> getOpaqueEnvelopes()

Description copied from interface: OpaqueEnvelopeOutboundConnector

A flux of OpaqueEnvelopes, which provide an opaque envelopes with any payload for a certain time period.

Specified by:

getOpaqueEnvelopes in interface OpaqueEnvelopeOutboundConnector

Returns:

A flux of opaque envelopes to be sent to the region-connector.

process

@KafkaListener(groupId="opaque-envelope-group",
               id="eddie-opaque-envelope-listener",
               topics="fw.${outbound-connector.kafka.eddie-id}.agnostic.opaque-envelope",
               containerFactory="opaqueEnvelopeListenerContainerFactory")
public void process(@Payload
 OpaqueEnvelope payload)