public class ShardTimeoutException extends TimeoutException
NoSQLSubscriber.onWarn(Throwable)
, which, unlike
NoSQLSubscriber.onError(Throwable)
, intends to raise a
warning to subscriber without cancelling ongoing subscription.Modifier and Type | Method and 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.
|
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
public long getLastMsgTime()
public long getTimeoutMs()
public int getShardId()
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.