teetime.framework

Class Configuration

java.lang.Object

teetime.framework.CompositeStage

teetime.framework.Configuration

public class Configuration
extends CompositeStage

Represents a configuration of connected stages. Available to be extended.

Since:

2.0

Author:

Christian Wulf, Nelson Tavares de Sousa

Field Summary

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Constructor and Description
Configuration()
Configuration(AbstractExceptionListenerFactory<?> factory)
Configuration(AbstractExceptionListenerFactory<?> factory, ConfigurationContext context) Deprecated. since 3.0. Scheduled to be removed in 3.1 or above. Use Configuration(AbstractExceptionListenerFactory) instead.

Method Summary

Modifier and Type	Method and Description
<T> void	connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity) Connects to ports with a pipe of a certain capacity
<T> void	connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity, IPipeFactory pipeFactory)
<T> void	connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, IPipeFactory pipeFactory)
<O> ConfigurationBuilder.Connection<O>	from(AbstractProducerStage<O> stage)
void	registerCustomPipe(AbstractPipe<?> pipe) Deprecated. since 3.0. Use connectPorts(OutputPort, InputPort, IPipeFactory) instead.

Methods inherited from class teetime.framework.CompositeStage

connectPorts, createInputPort, createOutputPort

Methods inherited from class java.lang.Object

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

Constructor Detail

Configuration

public Configuration()

Configuration

public Configuration(AbstractExceptionListenerFactory<?> factory)

Parameters:

factory - to define a common exception behavior

Configuration

@Deprecated
public Configuration(AbstractExceptionListenerFactory<?> factory,
                                 ConfigurationContext context)

Deprecated. since 3.0. Scheduled to be removed in 3.1 or above. Use Configuration(AbstractExceptionListenerFactory) instead.

Parameters:

factory - that defines a common exception behavior

context - that includes the scheduler algorithm to use

Method Detail

registerCustomPipe

@Deprecated
public void registerCustomPipe(AbstractPipe<?> pipe)

Deprecated. since 3.0. Use connectPorts(OutputPort, InputPort, IPipeFactory) instead.

Register pipes if your configuration only relies on custom pipes and therefore CompositeStage.connectPorts(OutputPort, InputPort) is never called.

Parameters:

pipe - A custom pipe instance

connectPorts

public <T> void connectPorts(OutputPort<? extends T> sourcePort,
                             InputPort<T> targetPort,
                             int capacity)

Description copied from class: CompositeStage

Connects to ports with a pipe of a certain capacity

Overrides:

connectPorts in class CompositeStage

Type Parameters:

T - the type of elements to be sent

Parameters:

sourcePort - OutputPort of the sending stage

targetPort - InputPort of the sending stage

capacity - the pipe is set to this capacity, if the value is greater than 0. If it is 0, than the pipe is unbounded, thus growing of the pipe is enabled.

connectPorts

public <T> void connectPorts(OutputPort<? extends T> sourcePort,
                             InputPort<T> targetPort,
                             IPipeFactory pipeFactory)

connectPorts

public <T> void connectPorts(OutputPort<? extends T> sourcePort,
                             InputPort<T> targetPort,
                             int capacity,
                             IPipeFactory pipeFactory)

from

public <O> ConfigurationBuilder.Connection<O> from(AbstractProducerStage<O> stage)