Class MdRequester

java.lang.Object

com.trdp.md.MdRequester

All Implemented Interfaces:

AutoCloseable

public class MdRequester
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
MdRequester(int localPort)
MdRequester(int localPort, long replyTimeoutUs)
MdRequester(int localPort, long replyTimeoutUs, long connectTimeoutUs)
MdRequester(int localPort, long replyTimeoutUs, long connectTimeoutUs, InetAddress bindAddress, int ttl, int qos)	Creates an MD requester with custom socket options.

Method Summary

Modifier and Type	Method	Description
void	close()
long	getConnectTimeoutUs()
long	getReplyTimeoutUs()
CompletableFuture<MdReply>	sendRequest(int comId, byte[] data, String destinationAddress, int destinationPort)
CompletableFuture<MdReply>	sendRequest(int comId, byte[] data, String destinationAddress, int destinationPort, TransportProtocol protocol)
CompletableFuture<MdReply>	sendRequest(int comId, byte[] data, String destinationAddress, int destinationPort, TransportProtocol protocol, String sourceUri, String destinationUri)
CompletableFuture<MdReply>	sendRequest(int comId, byte[] data, String destinationAddress, int destinationPort, TransportProtocol protocol, String sourceUri, String destinationUri, long perRequestReplyTimeoutUs)
CompletableFuture<MdReply>	sendRequest(int comId, byte[] data, String destinationAddress, int destinationPort, TransportProtocol protocol, String sourceUri, String destinationUri, long perRequestReplyTimeoutUs, int maxRetries)
void	setTopologyCounters(int etbTopoCnt, int opTrnTopoCnt)

Methods inherited from class Object

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

Constructor Details

MdRequester

public MdRequester(int localPort)
            throws IOException

Throws:

IOException

MdRequester

public MdRequester(int localPort,
 long replyTimeoutUs)
            throws IOException

Throws:

IOException

MdRequester

public MdRequester(int localPort,
 long replyTimeoutUs,
 long connectTimeoutUs,
 InetAddress bindAddress,
 int ttl,
 int qos)
            throws IOException

Creates an MD requester with custom socket options.

Parameters:

localPort - the local UDP port to bind to (0 for ephemeral)

replyTimeoutUs - the default reply timeout in microseconds

connectTimeoutUs - the TCP connect/idle timeout in microseconds

bindAddress - the local address to bind to, or null for wildcard

ttl - the IP time-to-live for outgoing packets

qos - the QoS value (IP Precedence 0..7)

Throws:

IOException - if socket creation or listener start fails

MdRequester

public MdRequester(int localPort,
 long replyTimeoutUs,
 long connectTimeoutUs)
            throws IOException

Throws:

IOException

Method Details

setTopologyCounters

public void setTopologyCounters(int etbTopoCnt,
 int opTrnTopoCnt)

getReplyTimeoutUs

public long getReplyTimeoutUs()

getConnectTimeoutUs

public long getConnectTimeoutUs()

sendRequest

public CompletableFuture<MdReply> sendRequest(int comId,
 byte[] data,
 String destinationAddress,
 int destinationPort)

sendRequest

public CompletableFuture<MdReply> sendRequest(int comId,
 byte[] data,
 String destinationAddress,
 int destinationPort,
 TransportProtocol protocol)

sendRequest

public CompletableFuture<MdReply> sendRequest(int comId,
 byte[] data,
 String destinationAddress,
 int destinationPort,
 TransportProtocol protocol,
 String sourceUri,
 String destinationUri)

sendRequest

public CompletableFuture<MdReply> sendRequest(int comId,
 byte[] data,
 String destinationAddress,
 int destinationPort,
 TransportProtocol protocol,
 String sourceUri,
 String destinationUri,
 long perRequestReplyTimeoutUs)

sendRequest

public CompletableFuture<MdReply> sendRequest(int comId,
 byte[] data,
 String destinationAddress,
 int destinationPort,
 TransportProtocol protocol,
 String sourceUri,
 String destinationUri,
 long perRequestReplyTimeoutUs,
 int maxRetries)

close

public void close()

Specified by:

close in interface AutoCloseable