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

Constructors

Constructor	Description
AmqpInbound(com.rabbitmq.client.amqp.Connection connection, MessageSerde serde, TopicConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<Pair<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope>>	getTerminationMessages()	A flux of termination documents, which are special permission market documents, and an optional region-connector ID as String.
reactor.core.publisher.Flux<RetransmissionRequest>	retransmissionRequests()	A flux of RetransmissionRequests.
void	setRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream)	Sets the stream of RetransmissionRequest to be sent to the EP app.

Methods inherited from class java.lang.Object

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

Constructor Details

AmqpInbound

public AmqpInbound(com.rabbitmq.client.amqp.Connection connection,
 MessageSerde serde,
 TopicConfiguration config)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

getTerminationMessages

public reactor.core.publisher.Flux<Pair<String,energy.eddie.cim.v0_82.pmd.PermissionEnvelope>> getTerminationMessages()

Description copied from interface: TerminationConnector

A flux of termination documents, which are special permission market documents, and an optional region-connector ID as String.

Specified by:

getTerminationMessages in interface TerminationConnector

Returns:

A pair of an optional region-connector ID and a termination market document.

retransmissionRequests

public reactor.core.publisher.Flux<RetransmissionRequest> retransmissionRequests()

Description copied from interface: RetransmissionOutboundConnector

A flux of RetransmissionRequests. This is consumed by RetransmissionRequestRouter to route the retransmission requests to the correct region-connector.

Specified by:

retransmissionRequests in interface RetransmissionOutboundConnector

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: RetransmissionOutboundConnector

Sets the stream of RetransmissionRequest to be sent to the EP app. This stream will be provided by the RetransmissionRequestRouter .

Specified by:

setRetransmissionResultStream in interface RetransmissionOutboundConnector

Parameters:

retransmissionResultStream - stream of retransmission results