Package | Description |
---|---|
com.tangosol.net |
Contains basic cluster interfaces and factories.
|
com.tangosol.net.cache |
Contains classes providing various caching strategies.
|
com.tangosol.persistence |
Contains classes and helpers for implementing various types of persistence.
|
com.tangosol.util |
Contains various generic utilities.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FlowControl.checkBacklog(Continuation<Void> continueNormal)
Check for an excessive backlog and if the underlying communication channel
is indeed clogged, call the specified continuation when the backlog is
back to normal or the service terminates.
|
void |
NonBlockingInvocable.run(Continuation cont)
Called exactly once by the InvocationService to execute this task.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ContinuousQueryCache.ConverterAsynchronousProcessor.checkBacklog(Continuation continueNormal) |
Modifier and Type | Class and Description |
---|---|
static class |
AbstractPersistenceEnvironment.DefaultFailureContinuation
Continuation implementation that accepts a Throwable and throws a
PersistenceException.
|
Modifier and Type | Field and Description |
---|---|
protected Continuation<? super T> |
SafePersistenceWrappers.SafePersistenceEnvironment.f_contFailure
The failure continuation for this environment.
|
protected Continuation<? super T> |
SafePersistenceWrappers.SafePersistenceManager.f_contFailure
The failure continuation for this manager.
|
protected Continuation<? super T> |
SafePersistenceWrappers.SafePersistentStore.f_contFailure
The failure continuation for this store.
|
Modifier and Type | Method and Description |
---|---|
Continuation<? super T> |
SafePersistenceWrappers.FailureContinuationFactory.getEnvironmentContinuation(com.oracle.coherence.persistence.PersistenceEnvironment<R> env)
Return a failure continuation to handle unexpected exceptions thrown
by operations against the specified PersistenceEnvironment.
|
Continuation<? super T> |
SafePersistenceWrappers.FailureContinuationFactory.getManagerContinuation(com.oracle.coherence.persistence.PersistenceManager<R> mgr)
Return a failure continuation to handle unexpected exceptions thrown
by operations against the specified PersistenceManager.
|
Continuation<? super T> |
SafePersistenceWrappers.FailureContinuationFactory.getStoreContinuation(com.oracle.coherence.persistence.PersistentStore<R> store)
Return a failure continuation to handle unexpected exceptions thrown
by operations against the specified PersistentStore.
|
Modifier and Type | Method and Description |
---|---|
protected static <R,T extends Throwable> |
SafePersistenceWrappers.getSimpleFactory(Continuation<? super T> cont)
Return a simple FailureContinuationFactory that uses the specified failure
continuation to handle failures at any layer of the persistence
implementation.
|
Constructor and Description |
---|
SafePersistenceEnvironment(com.oracle.coherence.persistence.PersistenceEnvironment<R> env,
Continuation<? super Throwable> cont)
Construct a PersistenceEnvironment backed by the specified environment.
|
SafePersistenceManager(com.oracle.coherence.persistence.PersistenceManager<R> mgr,
Continuation<? super Throwable> cont)
Construct a SafePersistenceManager backed by the specified manager.
|
SafePersistentStore(com.oracle.coherence.persistence.PersistentStore<R> store,
Continuation<? super T> cont)
Construct a SafePersistentStore backed by the specified store.
|
Modifier and Type | Class and Description |
---|---|
static class |
NullImplementation.NullContinuation<R>
A Continuation that does nothing.
|
protected class |
NullImplementation.NullPersistentStore.Token
Token returned by
NullImplementation.NullPersistentStore.begin(Collector, Object) . |
Modifier and Type | Method and Description |
---|---|
static <R> Continuation<R> |
NullImplementation.getContinuation()
Factory method: Obtain a null implementation of a
Continuation . |
Modifier and Type | Method and Description |
---|---|
boolean |
AsynchronousAgent.checkBacklog(Continuation<Void> continueNormal) |