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

Class FixedRateSource.TransportFixedRateSource.TransportFixedRateParams

java.lang.Object

de.iip_ecosphere.platform.services.environment.services.FixedRateSource.FixedRateParams

de.iip_ecosphere.platform.services.environment.services.FixedRateSource.TransportFixedRateSource.TransportFixedRateParams

Enclosing class:

FixedRateSource.TransportFixedRateSource<D>

public static class FixedRateSource.TransportFixedRateSource.TransportFixedRateParams
extends FixedRateSource.FixedRateParams

A parameter/configuration object for the FixedRateSource.

Author:

Holger Eichelberger, SSE

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
TransportFixedRateParams(long fixedDelay, long maxMessagesPerPoll, int duration)	Creates a fixed rate parameters object.
TransportFixedRateParams(long fixedDelay, long maxMessagesPerPoll, int duration, Supplier<String> headlineSupplier)	Creates a fixed rate parameters object.

Method Summary

Modifier and Type	Method	Description
String	getChannel()	Returns the default transport channel.
de.iip_ecosphere.platform.transport.connectors.TransportConnector	getConnector()	Returns the transport connector.
FixedRateSource.TransportFixedRateSource.TransportFixedRateParams	with(de.iip_ecosphere.platform.transport.connectors.TransportConnector connector, String channel)	Specifies the transport settings.

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

getDuration, getFixedDelay, getHeadlineSupplier, getMaxMessagesPerPoll

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

TransportFixedRateParams

public TransportFixedRateParams(long fixedDelay,
 long maxMessagesPerPoll,
 int duration)

Creates a fixed rate parameters object.

Parameters:

fixedDelay - the fixed delay between two polls/ingestions in ms

maxMessagesPerPoll - the (maximum) number of messages per poll

duration - the overall duration of the run/experiment in ms

TransportFixedRateParams

public TransportFixedRateParams(long fixedDelay,
 long maxMessagesPerPoll,
 int duration,
 Supplier<String> headlineSupplier)

Creates a fixed rate parameters object.

Parameters:

fixedDelay - the fixed delay between two polls/ingestions in ms

maxMessagesPerPoll - the (maximum) number of messages per poll

duration - the overall duration of the run/experiment in ms

headlineSupplier - the headline text supplier, may be null

Method Details

with

public FixedRateSource.TransportFixedRateSource.TransportFixedRateParams with(de.iip_ecosphere.platform.transport.connectors.TransportConnector connector,
 String channel)

Specifies the transport settings.

Parameters:

connector - the connector instance to use

channel - the default channel on connector to use

Returns:

this for chaining

getConnector

public de.iip_ecosphere.platform.transport.connectors.TransportConnector getConnector()

Returns the transport connector.

Returns:

the connector

getChannel

public String getChannel()

Returns the default transport channel.

Returns:

the channel