Package com.scaleoutsoftware.digitaltwin.hosting

Class DigitalTwinWorker

java.lang.Object

com.scaleoutsoftware.digitaltwin.hosting.DigitalTwinWorker

public class DigitalTwinWorker
extends java.lang.Object

DigitalTwinWorker orchestrates DigitalTwin model and ScaleOut event registration.

Constructor Summary

Constructors

Constructor	Description
DigitalTwinWorker()	Instantiates this builder

Method Summary

Modifier and Type	Method	Description
void	addAlertProvider(AlertProviderConfiguration configuration)
void	addAzureDigitalTwinPersistence(java.lang.String digitalTwinModel, java.lang.String azureDigitalTwinModelName)
void	addCosmosDbPersistence(java.lang.String digitalTwinModel)
void	addDefaultPersistence(java.lang.String digitalTwinModel)
<T extends DigitalTwinBase,V> void	addDigitalTwin(java.lang.String digitalTwinModel, MessageProcessor<T,V> digitalTwinMessageProcessor, java.lang.Class<T> dtType, java.lang.Class<V> valueClass)
<T extends DigitalTwinBase,V> void	addDigitalTwinWithSimulationSupport(java.lang.String digitalTwinModel, MessageProcessor<T,V> digitalTwinMessageProcessor, SimulationProcessor<T> digitalTwinSimulationProcessor, java.lang.Class<T> dtType, java.lang.Class<V> valueClass)
void	addDynamoDbPersistence(java.lang.String digitalTwinModel)
void	addSqlitePersistence(java.lang.String digitalTwinModel)
void	addSqlServerPersistence(java.lang.String digitalTwinModel)
void	enableMessageRecording(java.lang.String digitalTwinModel)
static com.scaleout.client.GridConnection	getGridConnection()
void	waitForEvents()

Methods inherited from class java.lang.Object

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

Constructor Detail

DigitalTwinWorker

public DigitalTwinWorker()

Instantiates this builder

Method Detail

addDigitalTwin

public <T extends DigitalTwinBase,V> void addDigitalTwin(java.lang.String digitalTwinModel,
                                                               MessageProcessor<T,V> digitalTwinMessageProcessor,
                                                               java.lang.Class<T> dtType,
                                                               java.lang.Class<V> valueClass)
                                                        throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addDigitalTwinWithSimulationSupport

public <T extends DigitalTwinBase,V> void addDigitalTwinWithSimulationSupport(java.lang.String digitalTwinModel,
                                                                                    MessageProcessor<T,V> digitalTwinMessageProcessor,
                                                                                    SimulationProcessor<T> digitalTwinSimulationProcessor,
                                                                                    java.lang.Class<T> dtType,
                                                                                    java.lang.Class<V> valueClass)
                                                                             throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addAlertProvider

public void addAlertProvider(AlertProviderConfiguration configuration)
                      throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addAzureDigitalTwinPersistence

public void addAzureDigitalTwinPersistence(java.lang.String digitalTwinModel,
                                           java.lang.String azureDigitalTwinModelName)
                                    throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addSqlitePersistence

public void addSqlitePersistence(java.lang.String digitalTwinModel)
                          throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addSqlServerPersistence

public void addSqlServerPersistence(java.lang.String digitalTwinModel)
                             throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addDynamoDbPersistence

public void addDynamoDbPersistence(java.lang.String digitalTwinModel)
                            throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addCosmosDbPersistence

public void addCosmosDbPersistence(java.lang.String digitalTwinModel)
                            throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

addDefaultPersistence

public void addDefaultPersistence(java.lang.String digitalTwinModel)
                           throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

enableMessageRecording

public void enableMessageRecording(java.lang.String digitalTwinModel)
                            throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

waitForEvents

public void waitForEvents()
                   throws DigitalTwinRegistrationException

Throws:

DigitalTwinRegistrationException

getGridConnection

public static com.scaleout.client.GridConnection getGridConnection()