org.apache.qpid.test.utils

Class TCPTunneler

java.lang.Object

org.apache.qpid.test.utils.TCPTunneler

All Implemented Interfaces:

AutoCloseable

public class TCPTunneler
extends Object
implements AutoCloseable

A basic implementation of TCP traffic forwarder between ports. It is intended to use in tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TCPTunneler.TunnelListener

Constructor Summary

Constructors

Constructor and Description
TCPTunneler(int localPort, String remoteHost, int remotePort, int numberOfConcurrentClients)

Method Summary

Modifier and Type	Method and Description
void	addClientListener(TCPTunneler.TunnelListener listener)
void	close()
void	disconnect(InetSocketAddress address)
void	removeClientListener(TCPTunneler.TunnelListener listener)
void	start()
void	stop()
void	stopClientToServerForwarding(InetSocketAddress clientAddress)

Methods inherited from class java.lang.Object

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

Constructor Detail

TCPTunneler

public TCPTunneler(int localPort,
                   String remoteHost,
                   int remotePort,
                   int numberOfConcurrentClients)

Method Detail

start

public void start()
           throws IOException

Throws:

IOException

stopClientToServerForwarding

public void stopClientToServerForwarding(InetSocketAddress clientAddress)

stop

public void stop()

addClientListener

public void addClientListener(TCPTunneler.TunnelListener listener)

removeClientListener

public void removeClientListener(TCPTunneler.TunnelListener listener)

disconnect

public void disconnect(InetSocketAddress address)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception