Package org.rasdaman.rasnet.communication

Class RasmgrKeepAlive

java.lang.Object
org.rasdaman.rasnet.communication.RasmgrKeepAlive
public class RasmgrKeepAlive extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    RasmgrKeepAlive(org.rasdaman.rasnet.service.RasmgrClientServiceGrpc.RasmgrClientServiceBlockingStub rasmgrService, int clientID, long aliveIntervalMilliseconds)
    Create a new RasmgrKeepAlive object that, when started, connects throw the given RasmgrClientServiceGrpc to the rasmgr and sends keep alive messages.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    finalize()
    If the stop method was not called, this method will call it.
    boolean
    isRunning()
    Check if the worker thread is running.
    void
    start()
    Creates and starts a thread that will send KeepAlive messages to the server.
    void
    stop()
    Stop the thread that is sending KeepAlive messages to the server.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • RasmgrKeepAlive

      public RasmgrKeepAlive(org.rasdaman.rasnet.service.RasmgrClientServiceGrpc.RasmgrClientServiceBlockingStub rasmgrService, int clientID, long aliveIntervalMilliseconds)
      Create a new RasmgrKeepAlive object that, when started, connects throw the given RasmgrClientServiceGrpc to the rasmgr and sends keep alive messages.
      Parameters:
      rasmgrService - GRPC service that is connected to a rasserver
      clientID - String that uniquely identifies the client on the server
      aliveIntervalMilliseconds - The number of milliseconds between each heart beat.

  • Method Details

    • start

      public void start()
      Creates and starts a thread that will send KeepAlive messages to the server. After this method is called, stop must be called. This method can be called only once.

    • isRunning

      public boolean isRunning()
      Check if the worker thread is running.
      Returns:

    • stop

      public void stop()
      Stop the thread that is sending KeepAlive messages to the server.

    • finalize

      protected void finalize() throws Throwable
      If the stop method was not called, this method will call it.
      Overrides:
      finalize in class Object
      Throws:
      Throwable