util
Class MultiInputConsumerQueue

java.lang.Object
  |
  +--util.MultiInputConsumerQueue

public class MultiInputConsumerQueue

extends Object

This class is modelled after the same behavoir as that of the ConsumerQueue except that it allows for mulitple channel inputs.

Version:

$Revision:

Author:

Dave Jurgens

, James Brodman

Field Summary

private HashMap

map

Constructor Summary

MultiInputConsumerQueue()

Method Summary

void	addInputChannel(connect.ConsumerChannel channel)
Object	dequeue(connect.ConsumerChannel c)
util.ReturnValue	dequeue(connect.ConsumerChannel c, int requestID)
boolean	isChannelActive(connect.ConsumerChannel c) Returns true if the channel is still being actively read from.
void	stopChannel(connect.ConsumerChannel c) Stops the specified channel.

Methods inherited from class java.lang.Object

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

Field Detail

map

private HashMap map

Constructor Detail

MultiInputConsumerQueue

public MultiInputConsumerQueue()

Method Detail

addInputChannel

public void addInputChannel(connect.ConsumerChannel channel)

dequeue

public util.ReturnValue dequeue(connect.ConsumerChannel c,
                                int requestID)

dequeue

public Object dequeue(connect.ConsumerChannel c)

isChannelActive

public boolean isChannelActive(connect.ConsumerChannel c)

Returns true if the channel is still being actively read from.

stopChannel

public void stopChannel(connect.ConsumerChannel c)

Stops the specified channel.