Package oracle.kv.pubsub

Class ShardTimeoutException

  • All Implemented Interfaces:
    java.io.Serializable
    public class ShardTimeoutException
extends java.util.concurrent.TimeoutException
    Exception raised when publisher does not hear from source shard for a given period of time. This exception is only used in calls to NoSQLSubscriber.onWarn(Throwable), which, unlike NoSQLSubscriber.onError(Throwable), intends to raise a warning to subscriber without cancelling ongoing subscription.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long getLastMsgTime()
      Returns the last time we heard from that given shard
      int getShardId()
      Returns Id of the shard that has not been heard from long enough
      long getTimeoutMs()
      Returns the time out of the period the given shard has not been heard.

      • Methods inherited from class java.lang.Throwable

        addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • getLastMsgTime

        public long getLastMsgTime()
        Returns the last time we heard from that given shard
        Returns:
        the timestamp of the last message

      • getTimeoutMs

        public long getTimeoutMs()
        Returns the time out of the period the given shard has not been heard.
        Returns:
        time out limit

      • getShardId

        public int getShardId()
        Returns Id of the shard that has not been heard from long enough
        Returns:
        Id of the shard