info.pppc.base.plugin.common.routing

Class RoutingOperation

java.lang.Object

info.pppc.base.plugin.common.routing.RoutingOperation

All Implemented Interfaces:

IOperation

public class RoutingOperation
extends java.lang.Object
implements IOperation

The forwarding operation forwards data from one stream to another.

Author:

Marcus Handte

Field Summary

Fields

Modifier and Type	Field and Description
static int	FORWARD_BUFFER The amount of buffer allocated for forwarding a single flow.

Constructor Summary

Constructors

Constructor and Description
RoutingOperation(IStreamConnector cin, IStreamConnector cout, NullMonitor monitor) Creates a new forwarding operation that synchronized with closing the input connector onto the passed monitor.

Method Summary

Methods

Modifier and Type	Method and Description
void	perform(IMonitor monitor) Reads from the input and writes to the output until the input is closed or the operation is canceled.

Methods inherited from class java.lang.Object

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

Field Detail

FORWARD_BUFFER

public static final int FORWARD_BUFFER

The amount of buffer allocated for forwarding a single flow.

See Also:

Constant Field Values

Constructor Detail

RoutingOperation

public RoutingOperation(IStreamConnector cin,
                IStreamConnector cout,
                NullMonitor monitor)

Creates a new forwarding operation that synchronized with closing the input connector onto the passed monitor.

Parameters:

cin - The input connector to read from.

cout - The output connector to write to.

monitor - The monitor to wait for until closing.

Method Detail

perform

public void perform(IMonitor monitor)

Reads from the input and writes to the output until the input is closed or the operation is canceled.

Specified by:

perform in interface IOperation

Parameters:

monitor - The monitor to wait for.