Package energy.eddie.aiida.streamers

Class ConnectionStatusEventStream

java.lang.Object

energy.eddie.aiida.streamers.ConnectionStatusEventStream

@Component
public class ConnectionStatusEventStream
extends Object

Publishes changes of the ConnectionStatus of permissions as soon as an AiidaStreamer connects to or disconnects from the EDDIE framework.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ConnectionStatusEventStream.ConnectionStatusEvent

Constructor Summary

Constructors

Constructor	Description
ConnectionStatusEventStream()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ConnectionStatusEventStream.ConnectionStatusEvent>	events(UUID userId)	Returns the connection status changes of all permissions of the passed user.
void	publish(UUID userId, UUID permissionId, ConnectionStatus connectionStatus)	Publishes the new connection status of a permission.

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionStatusEventStream

public ConnectionStatusEventStream()

Method Details

publish

public void publish(UUID userId,
 UUID permissionId,
 ConnectionStatus connectionStatus)

Publishes the new connection status of a permission. Events are dropped if nobody is subscribed. Synchronized, as streamers publish from their own MQTT client threads.

events

public reactor.core.publisher.Flux<ConnectionStatusEventStream.ConnectionStatusEvent> events(UUID userId)

Returns the connection status changes of all permissions of the passed user.