net.grinder.communication

Class FanOutStreamSender

java.lang.Object

net.grinder.communication.FanOutStreamSender

All Implemented Interfaces:

Sender

public final class FanOutStreamSender
extends Object

Manages the sending of messages to many streams.

Author:

Philip Aston

Constructor Summary

Constructors

Constructor and Description
FanOutStreamSender(int numberOfThreads) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	add(OutputStream stream) Add a stream.
protected Address	getAddress(ResourcePool.Resource resource) We don't support addressing individual streams.
protected net.grinder.communication.ResourcePool	getResourcePool() Allow subclasses to access the resource pool.
boolean	isShutdown() Return whether we are shutdown.
protected OutputStream	resourceToOutputStream(ResourcePool.Resource resource) Return an output stream from a resource.
void	send(Message message) Send the given message.
void	shutdown() Shut down this sender.
protected void	writeAddressedMessage(Address address, Message message) Send a message.
protected void	writeMessage(Message message) Send a message.
protected static void	writeMessageToStream(Message message, OutputStream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

FanOutStreamSender

public FanOutStreamSender(int numberOfThreads)

Constructor.

Parameters:

numberOfThreads - Number of sender threads to use.

Method Detail

add

public void add(OutputStream stream)

Add a stream.

Parameters:

stream - The stream.

shutdown

public void shutdown()

Shut down this sender.

Specified by:

shutdown in interface Sender

resourceToOutputStream

protected OutputStream resourceToOutputStream(ResourcePool.Resource resource)

Return an output stream from a resource.

Parameters:

resource - The resource.

Returns:

The output stream.

getAddress

protected Address getAddress(ResourcePool.Resource resource)

We don't support addressing individual streams.

Parameters:

resource - The resource.

Returns:

The address, or null if the resource has no address.

writeMessage

protected final void writeMessage(Message message)
                           throws CommunicationException

Send a message.

Parameters:

message - The message.

Throws:

IOException - If an error occurs.

CommunicationException

writeAddressedMessage

protected final void writeAddressedMessage(Address address,
                         Message message)
                                    throws CommunicationException

Send a message.

Parameters:

message - The message.

Throws:

IOException - If an error occurs.

CommunicationException

getResourcePool

protected final net.grinder.communication.ResourcePool getResourcePool()

Allow subclasses to access the resource pool.

Returns:

The resource pool.

send

public final void send(Message message)
                throws CommunicationException

Send the given message.

Specified by:

send in interface Sender

Parameters:

message - A Message.

Throws:

CommunicationException - If an error occurs.

writeMessageToStream

protected static final void writeMessageToStream(Message message,
                        OutputStream stream)
                                          throws IOException

Throws:

IOException

isShutdown

public boolean isShutdown()

Return whether we are shutdown.

Returns:

true if and only if we are shut down.