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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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.