com.rhi.architecture.parc
Class LinkedListQueue

java.lang.Object
  com.rhi.architecture.parc.channel.AbstractChannel
      com.rhi.architecture.parc.LinkedListQueue

All Implemented Interfaces:

Channel, java.lang.Cloneable, Consumer, Supplier

public class LinkedListQueue

extends AbstractChannel

LinkedListQueue - general purpose implementation of Channel.

Since:

1.0

Author:

Pete McKinstry

Constructor Summary

LinkedListQueue()
Default constructor.

Method Summary

java.lang.Object	clone() Simple Object based clone() method.
java.util.Collection	pull(int max) Pull a set of records out of the channel for processing.
void	push(java.util.Collection collection) Push an entire collection into the channel.

Methods inherited from class com.rhi.architecture.parc.channel.AbstractChannel

log, notifyMonitors, registerMonitor

Methods inherited from class java.lang.Object

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

Constructor Detail

LinkedListQueue

public LinkedListQueue()

Default constructor.

Since:

1.0

Method Detail

push

public void push(java.util.Collection collection)
          throws ProcessingException

Push an entire collection into the channel. Useful for batch of an entire set of records.

Parameters:

collection - of records to enqueue.

Throws:

ProcessingException

Since:

1.0

pull

public java.util.Collection pull(int max)
                          throws ProcessingException

Pull a set of records out of the channel for processing.

Parameters:

max - - the max number of records to pull from the channel.

Returns:

Collection of records returned from channel.

Throws:

ProcessingException

Since:

1.0

clone

public java.lang.Object clone()

Simple Object based clone() method. The reason this is okay is because i'm counting on re-using the same channel between each filter. That's where the concurrency comes in & why i'm using Doug Lea's package in the first place. In this case, simple is good.

Specified by:

clone in interface Channel

Overrides:

clone in class AbstractChannel

Returns:

Queue object

Since:

1.0