final class NioTcpClient extends NioClient
Modifier and Type | Class and Description |
---|---|
private static class |
NioTcpClient.ChannelKey |
private static class |
NioTcpClient.ChannelState |
private static class |
NioTcpClient.Transaction |
NioClient.KeyProcessor
Modifier and Type | Field and Description |
---|---|
private static java.util.Map<NioTcpClient.ChannelKey,NioTcpClient.ChannelState> |
channelMap |
private static java.util.Queue<NioTcpClient.ChannelState> |
registrationQueue |
Constructor and Description |
---|
NioTcpClient() |
Modifier and Type | Method and Description |
---|---|
private static void |
checkTransactionTimeouts() |
private static void |
closeTcp() |
private static void |
processPendingRegistrations() |
(package private) static java.util.concurrent.CompletableFuture<byte[]> |
sendrecv(java.net.InetSocketAddress local,
java.net.InetSocketAddress remote,
Message query,
byte[] data,
java.time.Duration timeout) |
close, runSelector, selector, setCloseTask, setPacketLogger, setRegistrationsTask, setTimeoutTask, verboseLog
private static final java.util.Queue<NioTcpClient.ChannelState> registrationQueue
private static final java.util.Map<NioTcpClient.ChannelKey,NioTcpClient.ChannelState> channelMap
private static void processPendingRegistrations()
private static void checkTransactionTimeouts()
private static void closeTcp()
static java.util.concurrent.CompletableFuture<byte[]> sendrecv(java.net.InetSocketAddress local, java.net.InetSocketAddress remote, Message query, byte[] data, java.time.Duration timeout)