Package org.jgroups.tests

Class Probe.UdpRequester

java.lang.Object

org.jgroups.tests.Probe.Requester

org.jgroups.tests.Probe.UdpRequester

All Implemented Interfaces:

Runnable

Enclosing class:

Probe

protected class Probe.UdpRequester
extends Probe.Requester

Field Summary

Fields

Modifier and Type	Field	Description
protected final byte[]	buf
protected MulticastSocket	sock

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

dest, on_rsp, ON_RSP, passcode, request

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UdpRequester(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 MulticastSocket sock

buf

protected final byte[] buf

Constructor Details

UdpRequester

protected UdpRequester(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