Package energy.eddie.core.services
Class CoreRetransmissionRouter
java.lang.Object
energy.eddie.core.services.CoreRetransmissionRouter
- All Implemented Interfaces:
RetransmissionRequestRouter,AutoCloseable
@Service
public class CoreRetransmissionRouter
extends Object
implements RetransmissionRequestRouter, AutoCloseable
This service routes retransmission messages between the region connectors. It does that by using the
regionConnectorId, which should match the region connector id.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidregisterRetransmissionConnector(RetransmissionOutboundConnector retransmissionOutboundConnector) voidregisterRetransmissionService(String regionConnectorId, RegionConnectorRetransmissionService regionConnectorRetransmissionService) reactor.core.publisher.Flux<RetransmissionResult> Returns a stream of retransmission results.
-
Constructor Details
-
CoreRetransmissionRouter
public CoreRetransmissionRouter()
-
-
Method Details
-
registerRetransmissionService
public void registerRetransmissionService(String regionConnectorId, RegionConnectorRetransmissionService regionConnectorRetransmissionService) -
registerRetransmissionConnector
public void registerRetransmissionConnector(RetransmissionOutboundConnector retransmissionOutboundConnector) -
retransmissionResults
Description copied from interface:RetransmissionRequestRouterReturns a stream of retransmission results. EachRetransmissionRequestshould result in aRetransmissionResultbeing emitted.- Specified by:
retransmissionResultsin interfaceRetransmissionRequestRouter
-
close
- Specified by:
closein interfaceAutoCloseable- Throws:
Exception
-