Package io.deephaven.enterprise.comm.impl.nio

Class WClient

java.lang.Object

io.deephaven.enterprise.niowrapper.sched.NullIOHandler

io.deephaven.enterprise.comm.impl.nio.Client

io.deephaven.enterprise.comm.impl.nio.WClient

All Implemented Interfaces:

CommClient, IOHandler

public class WClient
extends Client

Extends the basic Client class with walleye-specifica related to delay monitoring, cache clients and so on. Created by IntelliJ IDEA. User: jrauser Date: Jul 23, 2008 Time: 11:33:02 AM To change this template use File | Settings | File Templates.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	WClient.EnvelopeHandler
static interface	WClient.EnvelopeHandlerFactory
static class	WClient.NullEnvelopeHandlerFactory

Nested classes/interfaces inherited from interface io.deephaven.enterprise.comm.api.CommClient

CommClient.Null

Field Summary

Fields inherited from class io.deephaven.enterprise.comm.impl.nio.Client

clock, connectionMonitor, connectionMonitorParams, currentConnection, log, logPrefix, roundTripTracker, sched, SYNC_TIMEOUT

Fields inherited from interface io.deephaven.enterprise.comm.api.CommClient

NULL

Constructor Summary

Constructors

Constructor	Description
WClient(String serviceName, CommServer server, com.fishlib.io.logger.Logger log, com.fishlib.base.clock.Clock clock, CommandHandler handler, CommBase.ConnectionStatusHandler connectionStatusHandler, Scheduler scheduler, @Nullable WClient.EnvelopeHandler envelopeHandler)
WClient(String serviceName, PooledMessage.Pool pool, com.fishlib.io.logger.Logger log, com.fishlib.base.clock.Clock clock, CommandHandler handler, ConnectionStatusHandlerEx connectionStatusHandlerEx, ConnectionMonitor monitor, ConnectionMonitor.Params monitorParams, Scheduler scheduler, @Nullable WClient.EnvelopeHandler envelopeHandler)
WClient(String serviceName, PooledMessage.Pool pool, com.fishlib.io.logger.Logger log, com.fishlib.base.clock.Clock clock, CommandHandler handler, CommBase.ConnectionStatusHandler connectionStatusHandler, ConnectionMonitor monitor, ConnectionMonitor.Params monitorParams, Scheduler scheduler, @Nullable WClient.EnvelopeHandler envelopeHandler)
WClient(String serviceName, String statsItemPrefix, PooledMessage.Pool pool, com.fishlib.io.logger.Logger log, com.fishlib.base.clock.Clock clock, CommandHandler handler, ConnectionStatusHandlerEx connectionStatusHandlerEx, ConnectionMonitor monitor, ConnectionMonitor.Params monitorParams, Scheduler scheduler, @Nullable WClient.EnvelopeHandler envelopeHandler)	Create a WClient where the statistics item prefix is specified, instead of using the service name.
WClient(String serviceName, String statsItemPrefix, PooledMessage.Pool pool, com.fishlib.io.logger.Logger log, com.fishlib.base.clock.Clock clock, CommandHandler handler, CommBase.ConnectionStatusHandler connectionStatusHandler, ConnectionMonitor monitor, ConnectionMonitor.Params monitorParams, Scheduler scheduler, @Nullable WClient.EnvelopeHandler envelopeHandler)	Create a WClient where the statistics item prefix is specified, instead of using the service name.

Method Summary

Modifier and Type	Method	Description
protected void	handleClientConnectionEstablished(ClientEntry entry)	Called when we establish a connection to the server.
protected void	handleClientConnectionLoss(ClientEntry entry)	Called when we lose the connection to the server.
protected void	handleClientPush(ClientEntry entry, com.fishlib.base.Command cmd)	Unsolicited commands from the server are sent here.
protected void	handleEnvelope(ClientEntry client, WObjectUtil.Envelope<com.fishlib.base.Command> envelope, long now)	Give the client a chance to examine every incoming envelope

Methods inherited from class io.deephaven.enterprise.comm.impl.nio.Client

disconnect, disconnect, doPreSynchronousCallback, isConnected, sendCommand, sendCommand, sendCommand, sendCommand, sendCommandAsync, sendCommandNoResponse, setPreSynchronousCallback, startJob, toString

Methods inherited from class io.deephaven.enterprise.niowrapper.sched.NullIOHandler

endJob, handleEOF, handleError, handleIncoming, handleOutgoing, handleTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.comm.api.CommClient

sendCommand, sendCommand, sendCommand, sendCommand, sendCommandAsync, sendCommandNoResponse

Constructor Details

WClient

public WClient(String serviceName,
 String statsItemPrefix,
 PooledMessage.Pool pool,
 com.fishlib.io.logger.Logger log,
 com.fishlib.base.clock.Clock clock,
 CommandHandler handler,
 CommBase.ConnectionStatusHandler connectionStatusHandler,
 ConnectionMonitor monitor,
 ConnectionMonitor.Params monitorParams,
 Scheduler scheduler,
 @Nullable
 @Nullable WClient.EnvelopeHandler envelopeHandler)

Create a WClient where the statistics item prefix is specified, instead of using the service name.

WClient

public WClient(String serviceName,
 PooledMessage.Pool pool,
 com.fishlib.io.logger.Logger log,
 com.fishlib.base.clock.Clock clock,
 CommandHandler handler,
 CommBase.ConnectionStatusHandler connectionStatusHandler,
 ConnectionMonitor monitor,
 ConnectionMonitor.Params monitorParams,
 Scheduler scheduler,
 @Nullable
 @Nullable WClient.EnvelopeHandler envelopeHandler)

WClient

public WClient(String serviceName,
 CommServer server,
 com.fishlib.io.logger.Logger log,
 com.fishlib.base.clock.Clock clock,
 CommandHandler handler,
 CommBase.ConnectionStatusHandler connectionStatusHandler,
 Scheduler scheduler,
 @Nullable
 @Nullable WClient.EnvelopeHandler envelopeHandler)

WClient

public WClient(String serviceName,
 String statsItemPrefix,
 PooledMessage.Pool pool,
 com.fishlib.io.logger.Logger log,
 com.fishlib.base.clock.Clock clock,
 CommandHandler handler,
 ConnectionStatusHandlerEx connectionStatusHandlerEx,
 ConnectionMonitor monitor,
 ConnectionMonitor.Params monitorParams,
 Scheduler scheduler,
 @Nullable
 @Nullable WClient.EnvelopeHandler envelopeHandler)

Create a WClient where the statistics item prefix is specified, instead of using the service name.

WClient

public WClient(String serviceName,
 PooledMessage.Pool pool,
 com.fishlib.io.logger.Logger log,
 com.fishlib.base.clock.Clock clock,
 CommandHandler handler,
 ConnectionStatusHandlerEx connectionStatusHandlerEx,
 ConnectionMonitor monitor,
 ConnectionMonitor.Params monitorParams,
 Scheduler scheduler,
 @Nullable
 @Nullable WClient.EnvelopeHandler envelopeHandler)

Method Details

handleEnvelope

protected void handleEnvelope(ClientEntry client,
 WObjectUtil.Envelope<com.fishlib.base.Command> envelope,
 long now)

Description copied from class: Client

Give the client a chance to examine every incoming envelope

Specified by:

handleEnvelope in class Client

handleClientPush

protected void handleClientPush(ClientEntry entry,
 com.fishlib.base.Command cmd)

Description copied from class: Client

Unsolicited commands from the server are sent here.

Specified by:

handleClientPush in class Client

handleClientConnectionEstablished

protected void handleClientConnectionEstablished(ClientEntry entry)

Description copied from class: Client

Called when we establish a connection to the server.

Specified by:

handleClientConnectionEstablished in class Client

handleClientConnectionLoss

protected void handleClientConnectionLoss(ClientEntry entry)

Description copied from class: Client

Called when we lose the connection to the server.

Specified by:

handleClientConnectionLoss in class Client