Package energy.eddie.regionconnector.de.eta.providers

Class DeConnectionStatusMessageProvider

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.DeConnectionStatusMessageProvider

All Implemented Interfaces:

ConnectionStatusMessageProvider, AutoCloseable

public class DeConnectionStatusMessageProvider
extends Object
implements ConnectionStatusMessageProvider

Provides connection status messages for the German (DE) region connector. This class streams connection status updates to outbound connectors. Note: This is NOT a @Component - it's registered as a bean in the Spring config to avoid ambiguity with the ConnectionStatusMessageHandler bean.

Constructor Summary

Constructors

Constructor	Description
DeConnectionStatusMessageProvider(ConnectionStatusMessageHandler<DePermissionRequest> handler)

Method Summary

Modifier and Type	Method	Description
void	close()	Emit a complete signal on the Flow in this method.
reactor.core.publisher.Flux<ConnectionStatusMessage>	getConnectionStatusMessageStream()	Data stream of all connection status updates created by this region connector.

Methods inherited from class java.lang.Object

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

Constructor Details

DeConnectionStatusMessageProvider

public DeConnectionStatusMessageProvider(ConnectionStatusMessageHandler<DePermissionRequest> handler)

Method Details

getConnectionStatusMessageStream

public reactor.core.publisher.Flux<ConnectionStatusMessage> getConnectionStatusMessageStream()

Description copied from interface: ConnectionStatusMessageProvider

Data stream of all connection status updates created by this region connector.

Specified by:

getConnectionStatusMessageStream in interface ConnectionStatusMessageProvider

Returns:

connection status message stream

close

public void close()
           throws Exception

Description copied from interface: ConnectionStatusMessageProvider

Emit a complete signal on the Flow in this method.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ConnectionStatusMessageProvider

Throws:

Exception