jconch.pipeline.impl
Class BoundedPipeLink<T>

java.lang.Object
  jconch.pipeline.PipeLink<T>
      jconch.pipeline.impl.BoundedPipeLink<T>

All Implemented Interfaces:

PipeElement

public class BoundedPipeLink<T>
extends PipeLink<T>

A pipe link with a specified upper bound on the queue length.

Constructor Summary

BoundedPipeLink(int maxElements)
Constructor.

Method Summary

Methods inherited from class jconch.pipeline.PipeLink

add, breakLink, clearQueue, get, getAddTimeout, getFetchTimeout, getQueueLength, getRemainingCapacity, registerSource, setAddTimeout, setFetchTimeout, start

Methods inherited from class java.lang.Object

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

Constructor Detail

BoundedPipeLink

public BoundedPipeLink(int maxElements)

Constructor.

Parameters:

maxElements - The maximum number of elements.

Throws:

java.lang.IllegalArgumentException - If the argument is not greater than zero.