public final class DatagridWireNetworkContext extends net.openhft.chronicle.network.VanillaNetworkContext<DatagridWireNetworkContext> implements net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>
Modifier and Type | Class and Description |
---|---|
static class |
DatagridWireNetworkContext.ConnectionDetails |
static class |
DatagridWireNetworkContext.Factory |
Constructor and Description |
---|
DatagridWireNetworkContext(@NotNull Asset asset,
String clusterName,
net.openhft.chronicle.network.TcpEventHandler.SocketReader socketReader) |
Modifier and Type | Method and Description |
---|---|
net.openhft.chronicle.network.ConnectionListener |
acquireConnectionListener() |
DatagridClusterContext |
clusterContext() |
net.openhft.chronicle.core.threads.EventLoop |
eventLoop() |
byte |
getLocalHostIdentifier() |
net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> |
handler() |
void |
onHandlerChanged(net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> handler) |
@NotNull Asset |
rootAsset() |
net.openhft.chronicle.network.TcpEventHandler.SocketReader |
socketReader() |
@NotNull String |
toString() |
heartbeatListener, heartbeatListener, heartbeatTimeoutMs, heartbeatTimeoutMs, isAcceptor, isAcceptor, networkStatsListener, networkStatsListener, performClose, serverThreadingStrategy, serverThreadingStrategy, sessionDetails, sessionDetails, shouldPerformCloseInBackground, socketChannel, socketChannel, socketReconnector, socketReconnector, threadSafetyCheck, throwExceptionIfClosedInSetter, wireOutPublisher, wireOutPublisher, wireType, wireType
assertCloseablesClosed, clearUsedByThread, close, createdHere, disableCloseableTracing, enableCloseableTracing, isClosed, isClosing, isInUserThread, performCloseInBackground, referenceId, resetUsedByThread, shouldWaitForClosed, throwExceptionIfClosed, unmonitor, waitForCloseablesToClose, waitForClosed, warnAndCloseIfNotClosed
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addConnectionListener, heartbeatListener, heartbeatListener, heartbeatTimeoutMs, heartbeatTimeoutMs, isAcceptor, isAcceptor, isUnchecked, networkStatsListener, networkStatsListener, newCid, periodicPriority, priority, serverThreadingStrategy, serverThreadingStrategy, sessionDetails, sessionDetails, socketChannel, socketChannel, socketReconnector, socketReconnector, timeProvider, wireOutPublisher, wireOutPublisher, wireType, wireType
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
public net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> handler()
@NotNull public @NotNull Asset rootAsset()
public void onHandlerChanged(net.openhft.chronicle.network.api.TcpHandler<DatagridWireNetworkContext> handler)
onHandlerChanged
in interface net.openhft.chronicle.network.NetworkContext<DatagridWireNetworkContext>
onHandlerChanged
in class net.openhft.chronicle.network.VanillaNetworkContext<DatagridWireNetworkContext>
public net.openhft.chronicle.core.threads.EventLoop eventLoop()
eventLoop
in interface net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>
public byte getLocalHostIdentifier()
getLocalHostIdentifier
in interface net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>
public DatagridClusterContext clusterContext()
clusterContext
in interface net.openhft.chronicle.network.cluster.ClusteredNetworkContext<DatagridWireNetworkContext>
public net.openhft.chronicle.network.TcpEventHandler.SocketReader socketReader()
public net.openhft.chronicle.network.ConnectionListener acquireConnectionListener()
acquireConnectionListener
in interface net.openhft.chronicle.network.NetworkContext<DatagridWireNetworkContext>
@NotNull public @NotNull String toString()
toString
in class net.openhft.chronicle.core.io.AbstractCloseable
Copyright © 2021. All rights reserved.