Package org.jgroups.tests

Class Probe.TcpRequester

java.lang.Object

org.jgroups.tests.Probe.Requester

org.jgroups.tests.Probe.TcpRequester

All Implemented Interfaces:

Runnable

Enclosing class:

Probe

protected class Probe.TcpRequester
extends Probe.Requester

Field Summary

Fields

Modifier and Type	Field	Description
protected InputStream	in
protected OutputStream	out
protected Socket	sock

Fields inherited from class org.jgroups.tests.Probe.Requester

dest, on_rsp, ON_RSP, passcode, request

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TcpRequester(SocketAddress dest, String request, String passcode, Consumer<ByteArray> on_rsp)

Method Summary

Modifier and Type	Method	Description
protected ByteArray	fetchResponse()
protected boolean	isRunning()
protected <T extends Probe.Requester> T	sendRequest(byte[] request)
protected <T extends Probe.Requester> T	start(InetAddress bind_addr, long timeout, int ttl)
protected <T extends Probe.Requester> T	stop()

Methods inherited from class org.jgroups.tests.Probe.Requester

createRequest, run, setResponseHandler

Methods inherited from class java.lang.Object

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

Field Details

sock

protected Socket sock

in

protected InputStream in

out

protected OutputStream out

Constructor Details

TcpRequester

protected TcpRequester(SocketAddress dest,
 String request,
 String passcode,
 Consumer<ByteArray> on_rsp)

Method Details

start

protected <T extends Probe.Requester> T start(InetAddress bind_addr,
 long timeout,
 int ttl)
                                       throws IOException

Specified by:

start in class Probe.Requester

Throws:

IOException

stop

protected <T extends Probe.Requester> T stop()

Specified by:

stop in class Probe.Requester

isRunning

protected boolean isRunning()

Specified by:

isRunning in class Probe.Requester

sendRequest

protected <T extends Probe.Requester> T sendRequest(byte[] request)
                                             throws IOException

Specified by:

sendRequest in class Probe.Requester

Throws:

IOException

fetchResponse

protected ByteArray fetchResponse()

Specified by:

fetchResponse in class Probe.Requester