Package io.deephaven.enterprise.controller.client

Class ControllerClientGrpc.ObserverImpl

java.lang.Object

io.deephaven.enterprise.controller.client.ControllerClientGrpc.ObserverImpl

All Implemented Interfaces:

ControllerClientGrpc.Observer

Enclosing class:

ControllerClientGrpc

public static class ControllerClientGrpc.ObserverImpl
extends Object
implements ControllerClientGrpc.Observer

A basic ControllerClientGrpc.Observer implementation with do-nothing methods.

Constructor Summary

Constructors

Constructor	Description
ObserverImpl()

Method Summary

Modifier and Type	Method	Description
void	handleConfigUpdate(ControllerConfigurationMessage configMessage)	Handle an update to the ControllerConfigurationMessage
void	handleConnectionEstablished()	Handle when the connection to the Controller has been established, or re-establisehd after a disconnection.
void	handleConnectionLost()	Handle when the connection to the Controller has been lost.
void	handlePut(PersistentQueryInfoMessage value)	Handle the addition of a query.
void	handleRemove(long querySerial)	Handle the removal of a query.

Methods inherited from class java.lang.Object

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

Constructor Details

ObserverImpl

public ObserverImpl()

Method Details

handleConfigUpdate

public void handleConfigUpdate(@NotNull
 ControllerConfigurationMessage configMessage)

Description copied from interface: ControllerClientGrpc.Observer

Handle an update to the ControllerConfigurationMessage

Specified by:

handleConfigUpdate in interface ControllerClientGrpc.Observer

Parameters:

configMessage - the new configuration

handleRemove

public void handleRemove(long querySerial)

Description copied from interface: ControllerClientGrpc.Observer

Handle the removal of a query.

Specified by:

handleRemove in interface ControllerClientGrpc.Observer

Parameters:

querySerial - the serial of the removed query

handlePut

public void handlePut(@NotNull
 PersistentQueryInfoMessage value)

Description copied from interface: ControllerClientGrpc.Observer

Handle the addition of a query.

Specified by:

handlePut in interface ControllerClientGrpc.Observer

Parameters:

value - the PersistentQueryInfoMessage of the query

handleConnectionLost

public void handleConnectionLost()

Description copied from interface: ControllerClientGrpc.Observer

Handle when the connection to the Controller has been lost.

Specified by:

handleConnectionLost in interface ControllerClientGrpc.Observer

handleConnectionEstablished

public void handleConnectionEstablished()

Description copied from interface: ControllerClientGrpc.Observer

Handle when the connection to the Controller has been established, or re-establisehd after a disconnection.

Specified by:

handleConnectionEstablished in interface ControllerClientGrpc.Observer