Package de.iip_ecosphere.platform.services.environment.services

Class FixedRateSource.TransportFixedRateSource<D>

java.lang.Object

de.iip_ecosphere.platform.services.environment.services.FixedRateSource<D>

de.iip_ecosphere.platform.services.environment.services.FixedRateSource.TransportFixedRateSource<D>

Type Parameters:

D - the type of data

Enclosing class:

FixedRateSource<D>

public abstract static class FixedRateSource.TransportFixedRateSource<D>
extends FixedRateSource<D>

Specializes the fixed-rate source for TransportConnector.

Author:

Holger Eichelberger, SSE

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FixedRateSource.TransportFixedRateSource.TransportFixedRateParams	A parameter/configuration object for the FixedRateSource.

Nested classes/interfaces inherited from class de.iip_ecosphere.platform.services.environment.services.FixedRateSource

FixedRateSource.FixedRateParams, FixedRateSource.TransportFixedRateSource<D>

Field Summary

Fields

Modifier and Type	Field	Description
private String	channel
private de.iip_ecosphere.platform.transport.connectors.TransportConnector	connector

Constructor Summary

Constructors

Constructor	Description
TransportFixedRateSource(Supplier<D> dataCreator, FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params)	Creates a transport-based fixed rate source.
TransportFixedRateSource(Supplier<D> dataCreator, FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params, DataIngestor<D> ingestor, Supplier<ServiceState> stateSupplier)	Creates a transport-based fixed rate source.
TransportFixedRateSource(Supplier<D> dataCreator, FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params, Supplier<ServiceState> stateSupplier)	Creates a transport-based fixed rate source.

Method Summary

Modifier and Type	Method	Description
protected void	disconnect()	Called to disconnect from the ingestor.
protected void	ingest(D data)	Is called to ingest data provided by FixedRateSource.dataCreator.
protected void	send(String channel, Object data)	Sends on the transport connector.
protected void	sendSafe(String channel, Object data)	Sends on the transport connector, logging exceptions.

Methods inherited from class de.iip_ecosphere.platform.services.environment.services.FixedRateSource

doStartExperiment, noIngestor, notifySent, notifyStarting, notifyStopping, runningState, setIngestor, start

Methods inherited from class java.lang.Object

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

Field Details

connector

private de.iip_ecosphere.platform.transport.connectors.TransportConnector connector

channel

private String channel

Constructor Details

TransportFixedRateSource

public TransportFixedRateSource(Supplier<D> dataCreator,
 FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params)

Creates a transport-based fixed rate source.

Parameters:

dataCreator - the data creator incrementally creating the data to ingest

params - the parameter/configuration object

TransportFixedRateSource

public TransportFixedRateSource(Supplier<D> dataCreator,
 FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params,
 Supplier<ServiceState> stateSupplier)

Creates a transport-based fixed rate source.

Parameters:

dataCreator - the data creator incrementally creating the data to ingest

params - the parameter/configuration object

TransportFixedRateSource

public TransportFixedRateSource(Supplier<D> dataCreator,
 FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params,
 DataIngestor<D> ingestor,
 Supplier<ServiceState> stateSupplier)

Creates a transport-based fixed rate source. Ingestion happens through ingestor rather than the supplied transport connector while explicit sending happens via the transport connector.

Parameters:

dataCreator - the data creator incrementally creating the data to ingest

params - the parameter/configuration object

stateSupplier - service state supplier

Method Details

disconnect

protected void disconnect()
                   throws IOException

Description copied from class: FixedRateSource

Called to disconnect from the ingestor.

Specified by:

disconnect in class FixedRateSource<D>

Throws:

IOException - if disconnecting fails

sendSafe

protected void sendSafe(String channel,
 Object data)

Sends on the transport connector, logging exceptions.

Parameters:

channel - the channel to send on

data - the data to send

send

protected void send(String channel,
 Object data)
             throws IOException

Sends on the transport connector.

Parameters:

channel - the channel to send on

data - the data to send

Throws:

IOException - if sending fails

ingest

protected void ingest(D data)
               throws IOException

Description copied from class: FixedRateSource

Is called to ingest data provided by FixedRateSource.dataCreator.

Overrides:

ingest in class FixedRateSource<D>

Parameters:

data - the data

Throws:

IOException - if ingesting fails