Package org.xbill.DNS

Class NioTcpClient

java.lang.Object

org.xbill.DNS.NioClient

org.xbill.DNS.NioTcpClient

All Implemented Interfaces:

TcpIoClient

final class NioTcpClient
extends NioClient
implements TcpIoClient

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	NioTcpClient.ChannelKey
private class	NioTcpClient.ChannelState
private static class	NioTcpClient.Transaction

Nested classes/interfaces inherited from class org.xbill.DNS.NioClient

NioClient.KeyProcessor

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<NioTcpClient.ChannelKey,NioTcpClient.ChannelState>	channelMap
private final Queue<NioTcpClient.ChannelState>	registrationQueue

Fields inherited from class org.xbill.DNS.NioClient

REGISTER_SHUTDOWN_HOOK_PROPERTY, SELECTOR_TIMEOUT_PROPERTY

Constructor Summary

Constructors

Constructor	Description
NioTcpClient()

Method Summary

Modifier and Type	Method	Description
private void	checkTransactionTimeouts()
private void	closeTcp()
private void	processPendingRegistrations(Selector selector)
CompletableFuture<byte[]>	sendAndReceiveTcp(InetSocketAddress local, InetSocketAddress remote, Message query, byte[] data, Duration timeout)	Sends a query to a remote server and returns the answer.

Methods inherited from class org.xbill.DNS.NioClient

close, runSelector, selector, setCloseTask, setPacketLogger, setRegistrationsTask, setTimeoutTask, verboseLog, verboseLog

Methods inherited from class java.lang.Object

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

Field Details

registrationQueue

private final Queue<NioTcpClient.ChannelState> registrationQueue

channelMap

private final Map<NioTcpClient.ChannelKey,NioTcpClient.ChannelState> channelMap

Constructor Details

NioTcpClient

NioTcpClient()

Method Details

processPendingRegistrations

private void processPendingRegistrations(Selector selector)

checkTransactionTimeouts

private void checkTransactionTimeouts()

closeTcp

private void closeTcp()

sendAndReceiveTcp

public CompletableFuture<byte[]> sendAndReceiveTcp(InetSocketAddress local,
 InetSocketAddress remote,
 Message query,
 byte[] data,
 Duration timeout)

Description copied from interface: TcpIoClient

Sends a query to a remote server and returns the answer.

Specified by:

sendAndReceiveTcp in interface TcpIoClient

Parameters:

local - Address from which the connection is coming. may be null and the implementation must decide on the local address.

remote - Address that the connection should send the data to.

query - DNS message representation of the outbound query.

data - Raw byte representation of the outbound query.

timeout - Duration before the connection will time out and be closed.

Returns:

A CompletableFuture that will be completed with the byte value of the response.