net.grinder.communication

Class ClientReceiver

java.lang.Object

net.grinder.communication.StreamReceiver

net.grinder.communication.ClientReceiver

All Implemented Interfaces:

Receiver

public final class ClientReceiver
extends StreamReceiver

Manages receipt of messages from a server over a TCP connection.

Author:

Philip Aston

Method Summary

Methods

Modifier and Type	Method and Description
static ClientReceiver	connect(Connector connector, Address address) Factory method that makes a TCP connection and returns a corresponding Receiver.
void	shutdown() Cleanly shut down the Receiver.

Methods inherited from class net.grinder.communication.StreamReceiver

waitForMessage

Methods inherited from class java.lang.Object

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

Method Detail

connect

public static ClientReceiver connect(Connector connector,
                     Address address)
                              throws CommunicationException

Factory method that makes a TCP connection and returns a corresponding Receiver.

Parameters:

connector - Connector to use to make the connection to the server.

address - The address of this ClientReceiver - can be used with FanOutServerSender.send(Address, Message).

Returns:

The ClientReceiver.

Throws:

CommunicationException - If failed to connect.

shutdown

public void shutdown()

Cleanly shut down the Receiver. Ignore errors, connection has probably been reset by peer.

Specified by:

shutdown in interface Receiver

Overrides:

shutdown in class StreamReceiver