Class RobustRPC
-
- All Implemented Interfaces:
public final class RobustRPC
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classRobustRPC.Companion
-
Field Summary
Fields Modifier and Type Field Description private final BooleanisActiveprivate final AtomicIntegerrpcFailuresprivate IntegermaxRPCFailurespublic final static RobustRPC.CompanionCompanion
-
Constructor Summary
Constructors Constructor Description RobustRPC(PulsarWebDriver driver)
-
Method Summary
Modifier and Type Method Description final BooleanisActive()final AtomicIntegergetRpcFailures()final IntegergetMaxRPCFailures()final UnitsetMaxRPCFailures(Integer maxRPCFailures)final <T extends Any> Tinvoke(String action, SuspendFunction0<T> block)final <T extends Any> TinvokeWithRetry(String action, Integer maxRetry, String url, SuspendFunction0<T> block)final <T extends Any> TinvokeSilently(String action, String message, SuspendFunction0<T> block)final <T extends Any> TinvokeDeferredSilently(String action, String url, String message, Integer maxRetry, SuspendFunction0<T> block)final UnithandleChromeException(ChromeDriverException e, String action, String message)final UnithandleChromeIOException(ChromeIOException e, String action, String message)final UnithandleChromeRPCException(ChromeRPCException e, String action, String message)-
-
Constructor Detail
-
RobustRPC
RobustRPC(PulsarWebDriver driver)
-
-
Method Detail
-
getRpcFailures
final AtomicInteger getRpcFailures()
-
getMaxRPCFailures
final Integer getMaxRPCFailures()
-
setMaxRPCFailures
final Unit setMaxRPCFailures(Integer maxRPCFailures)
-
invokeWithRetry
final <T extends Any> T invokeWithRetry(String action, Integer maxRetry, String url, SuspendFunction0<T> block)
-
invokeSilently
final <T extends Any> T invokeSilently(String action, String message, SuspendFunction0<T> block)
-
invokeDeferredSilently
final <T extends Any> T invokeDeferredSilently(String action, String url, String message, Integer maxRetry, SuspendFunction0<T> block)
-
handleChromeException
final Unit handleChromeException(ChromeDriverException e, String action, String message)
-
handleChromeIOException
final Unit handleChromeIOException(ChromeIOException e, String action, String message)
-
handleChromeRPCException
final Unit handleChromeRPCException(ChromeRPCException e, String action, String message)
-
-
-
-