Package energy.eddie.aiida.streamers

Class StreamerFactory

java.lang.Object

energy.eddie.aiida.streamers.StreamerFactory

public class StreamerFactory
extends Object

Method Summary

Modifier and Type	Method	Description
protected static AiidaStreamer	getAiidaStreamer(StreamerDependencies dependencies, Permission permission, reactor.core.publisher.Flux<AiidaRecord> recordFlux)	Creates a new AiidaStreamer applying the specified streamingConfig.

Methods inherited from class java.lang.Object

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

Method Details

getAiidaStreamer

protected static AiidaStreamer getAiidaStreamer(StreamerDependencies dependencies,
 Permission permission,
 reactor.core.publisher.Flux<AiidaRecord> recordFlux)
                                         throws org.eclipse.paho.mqttv5.common.MqttException

Creates a new AiidaStreamer applying the specified streamingConfig.

Parameters:

dependencies - Streamer dependencies shared by every streamer implementation.

permission - Permission for which to create the AiidaStreamer.

recordFlux - Flux on which the records that should be sent are published.

Throws:

org.eclipse.paho.mqttv5.common.MqttException - If the creation of the MqttClient failed.