Package energy.eddie.outbound.admin.console.services

Class RetransmissionAdminConsoleOutboundConnector

java.lang.Object

energy.eddie.outbound.admin.console.services.RetransmissionAdminConsoleOutboundConnector

All Implemented Interfaces:

RetransmissionOutboundConnector, AutoCloseable

@Component
public class RetransmissionAdminConsoleOutboundConnector
extends Object
implements RetransmissionOutboundConnector, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
RetransmissionAdminConsoleOutboundConnector()

Method Summary

Modifier and Type	Method	Description
void	close()
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

RetransmissionAdminConsoleOutboundConnector

public RetransmissionAdminConsoleOutboundConnector()

Method Details

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

close

public void close()

Specified by:

close in interface AutoCloseable