Package energy.eddie.regionconnector.shared.event.sourcing.handlers.integration

Class ConnectionStatusMessageHandler<T extends PermissionRequest>

java.lang.Object

energy.eddie.regionconnector.shared.event.sourcing.handlers.integration.ConnectionStatusMessageHandler<T>

All Implemented Interfaces:

ConnectionStatusMessageProvider, EventHandler<PermissionEvent>, AutoCloseable

public class ConnectionStatusMessageHandler<T extends PermissionRequest>
extends Object
implements EventHandler<PermissionEvent>, ConnectionStatusMessageProvider

Subscribes to all events of an EventBus and creates connection status messages based on an event.

Constructor Summary

Constructors

Constructor	Description
ConnectionStatusMessageHandler(EventBus eventBus, PermissionRequestRepository<T> repository, Function<T,String> messageFunc)
ConnectionStatusMessageHandler(EventBus eventBus, PermissionRequestRepository<T> repository, Function<T,String> messageFunc, Function<T,com.fasterxml.jackson.databind.JsonNode> additionalDataFunc)

Method Summary

Modifier and Type	Method	Description
void	accept(PermissionEvent permissionEvent)	Subscription method for the event bus
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

ConnectionStatusMessageHandler

public ConnectionStatusMessageHandler(EventBus eventBus,
 PermissionRequestRepository<T> repository,
 Function<T,String> messageFunc)

ConnectionStatusMessageHandler

public ConnectionStatusMessageHandler(EventBus eventBus,
 PermissionRequestRepository<T> repository,
 Function<T,String> messageFunc,
 Function<T,com.fasterxml.jackson.databind.JsonNode> additionalDataFunc)

Method Details

accept

public void accept(PermissionEvent permissionEvent)

Description copied from interface: EventHandler

Subscription method for the event bus

Specified by:

accept in interface EventHandler<T extends PermissionRequest>

Parameters:

permissionEvent - event that indicates that a permission request has been changed

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()

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