public class ServicePassivator extends Object
The invoke chain is split in the following steps
ServicePassivator .passivate() .withQuietDelay(ChronoUnit.SECONDS.getDuration().multipliedBy(20)) .monitor() .withTimeout(ChronoUnit.MINUTES.getDuration().multipliedBy(2)) .await() .proceed(() -> System.out.println("do something")) .onFailure(failure -> System.out.println("failed " + failure)) .onSuccess(() -> System.out.println("succeed"));*
Modifier and Type | Class and Description |
---|---|
static class |
ServicePassivator.Monitor
Monitors service lookups for stating about quiet status.
|
static class |
ServicePassivator.Passivator
Intercepts service lookups for implementing the quiet logic.
|
static interface |
ServicePassivator.RunnableCheckException<X extends Exception> |
static interface |
ServicePassivator.Termination
Terminates the pacification by a success or a failure action and release the lock.
|
static class |
ServicePassivator.Waiter
Terminates the chain by running the operation in a passivated context.
|
Constructor and Description |
---|
ServicePassivator() |
Modifier and Type | Method and Description |
---|---|
static ServicePassivator.Passivator |
passivate() |
static ServicePassivator.Termination |
proceed(Duration quiet,
Duration timeout,
boolean enforce,
Runnable runnable) |
static <X extends Exception> |
proceed(Duration quiet,
Duration timeout,
boolean enforce,
ServicePassivator.RunnableCheckException<Exception> runnable,
Class<X> oftype) |
public ServicePassivator()
public static ServicePassivator.Passivator passivate()
public static ServicePassivator.Termination proceed(Duration quiet, Duration timeout, boolean enforce, Runnable runnable)
Copyright © 2016 Nuxeo SA. All rights reserved.