net.grinder.communication
Class MessagePump

java.lang.Object
  net.grinder.communication.MessagePump

public final class MessagePump
extends Object

Active object that copies messages from a Receiver to a Sender.

Author:

Philip Aston

Constructor Summary

MessagePump(Receiver receiver, Sender sender, int numberOfThreads)
Constructor.

Method Summary

void	shutdown() Shut down the MessagePump.
void	start() Start the pump.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagePump

public MessagePump(Receiver receiver,
                   Sender sender,
                   int numberOfThreads)

Constructor.

Parameters:

receiver - Receiver to read messages from.

sender - Sender to send messages to.

numberOfThreads - Number of worker threads to use. Order is not guaranteed if more than one thread is used.

Method Detail

start

public void start()

Start the pump.

shutdown

public void shutdown()

Shut down the MessagePump.