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

Constructor	Description
CoreRetransmissionRouter()

Method Summary

Modifier and Type	Method	Description
void	close()
void	registerRetransmissionConnector(RetransmissionOutboundConnector retransmissionOutboundConnector)
void	registerRetransmissionService(String regionConnectorId, RegionConnectorRetransmissionService regionConnectorRetransmissionService)
reactor.core.publisher.Flux<RetransmissionResult>	retransmissionResults()	Returns a stream of retransmission results.

Methods inherited from class java.lang.Object

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

Constructor Details

CoreRetransmissionRouter

public CoreRetransmissionRouter()

Method Details

registerRetransmissionService

public void registerRetransmissionService(String regionConnectorId,
 RegionConnectorRetransmissionService regionConnectorRetransmissionService)

registerRetransmissionConnector

public void registerRetransmissionConnector(RetransmissionOutboundConnector retransmissionOutboundConnector)

retransmissionResults

public reactor.core.publisher.Flux<RetransmissionResult> retransmissionResults()

Description copied from interface: RetransmissionRequestRouter

Returns a stream of retransmission results. Each RetransmissionRequest should result in a RetransmissionResult being emitted.

Specified by:

retransmissionResults in interface RetransmissionRequestRouter

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception