Package energy.eddie.outbound.amqp
Class AmqpInbound
java.lang.Object
energy.eddie.outbound.amqp.AmqpInbound
- All Implemented Interfaces:
RetransmissionOutboundConnector,TerminationConnector,AutoCloseable
@Component
public class AmqpInbound
extends Object
implements TerminationConnector, RetransmissionOutboundConnector, AutoCloseable
-
Constructor Summary
ConstructorsConstructorDescriptionAmqpInbound(com.rabbitmq.client.amqp.Connection connection, MessageSerde serde, TopicConfiguration config) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()A flux of termination documents, which are special permission market documents, and an optional region-connector ID as String.reactor.core.publisher.Flux<RetransmissionRequest> A flux ofRetransmissionRequests.voidsetRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream) Sets the stream ofRetransmissionRequestto be sent to the EP app.
-
Constructor Details
-
Method Details
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-
getTerminationMessages
public reactor.core.publisher.Flux<Pair<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope>> getTerminationMessages()Description copied from interface:TerminationConnectorA flux of termination documents, which are special permission market documents, and an optional region-connector ID as String.- Specified by:
getTerminationMessagesin interfaceTerminationConnector- Returns:
- A pair of an optional region-connector ID and a termination market document.
-
retransmissionRequests
Description copied from interface:RetransmissionOutboundConnectorA flux ofRetransmissionRequests. This is consumed byRetransmissionRequestRouterto route the retransmission requests to the correct region-connector.- Specified by:
retransmissionRequestsin interfaceRetransmissionOutboundConnector- Returns:
- Contains the regionConnectorId, the permissionRequestId and the start and end date of the timeframe that should be retransmitted.
-
setRetransmissionResultStream
public void setRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream) Description copied from interface:RetransmissionOutboundConnectorSets the stream ofRetransmissionRequestto be sent to the EP app. This stream will be provided by theRetransmissionRequestRouter.- Specified by:
setRetransmissionResultStreamin interfaceRetransmissionOutboundConnector- Parameters:
retransmissionResultStream- stream of retransmission results
-