Package org.rasdaman.rasnet.communication

Class RasmgrKeepAlive

  • public class RasmgrKeepAlive
extends java.lang.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

      All Methods Instance Methods Concrete Methods 
      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 Detail

      • 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 Detail

      • 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 java.lang.Throwable
        If the stop method was not called, this method will call it.
        Overrides:
        finalize in class java.lang.Object
        Throws:
        java.lang.Throwable