Package | Description |
---|---|
org.forgerock.http.filter |
Core
Filter implementations. |
org.forgerock.http.filter.throttling |
This package contains the components used to implement a throttling rate support.
|
org.forgerock.http.protocol |
Models and manages elements of the Hypertext Transfer Protocol.
|
org.forgerock.openig.el |
Integrates with the Java Enterprise Edition Unified Expression Language API.
|
org.forgerock.util |
Provides common interfaces and classes.
|
org.forgerock.util.promise |
An implementation of the
Promise API in Java. |
Constructor and Description |
---|
ConditionalFilter(Filter delegate,
AsyncFunction<ContextAndRequest,Boolean,Exception> condition)
Constructs a
ConditionalFilter . |
Constructor and Description |
---|
MappedThrottlingPolicy(AsyncFunction<ContextAndRequest,String,Exception> throttlingRateMapper,
Map<String,ThrottlingRate> throttlingRatesMapping,
ThrottlingRate defaultRate)
Constructs a new
MappedThrottlingPolicy . |
ThrottlingFilter(AsyncFunction<ContextAndRequest,String,Exception> requestGroupingPolicy,
ThrottlingPolicy throttlingRatePolicy,
ThrottlingStrategy throttlingStrategy)
Constructs a ThrottlingFilter.
|
Modifier and Type | Method and Description |
---|---|
static <E extends Exception> |
Responses.internalServerError()
Utility method returning an async function that creates a
Response with status
Status.INTERNAL_SERVER_ERROR and the exception set as the cause. |
Modifier and Type | Class and Description |
---|---|
class |
ExpressionRequestAsyncFunction<V>
This is an implementation of the
AsyncFunction based on the evaluation of an Expression . |
Modifier and Type | Method and Description |
---|---|
V |
PerItemEvictionStrategyCache.getValue(K key,
Callable<V> callable,
AsyncFunction<V,Duration,Exception> expire)
Borrow (and create before hand if absent) a cache entry.
|
Constructor and Description |
---|
PerItemEvictionStrategyCache(ScheduledExecutorService executorService,
AsyncFunction<V,Duration,Exception> defaultTimeoutFunction)
Build a new
PerItemEvictionStrategyCache using the given scheduled executor. |
Modifier and Type | Method and Description |
---|---|
<VOUT> Promise<VOUT,E> |
PromiseImpl.thenAsync(AsyncFunction<? super V,VOUT,E> onResult) |
<VOUT> Promise<VOUT,E> |
Promise.thenAsync(AsyncFunction<? super V,VOUT,E> onResult)
Submits the provided asynchronous function for execution once this
Promise has completed with a result, and returns a new
Promise representing the outcome of the function. |
<VOUT,EOUT extends Exception> |
PromiseImpl.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException) |
<VOUT,EOUT extends Exception> |
PromiseImpl.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException) |
<VOUT,EOUT extends Exception> |
Promise.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException)
Submits the provided asynchronous functions for execution once this
Promise has completed, and returns a new Promise
representing the outcome of the invoked function. |
<VOUT,EOUT extends Exception> |
Promise.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException)
Submits the provided asynchronous functions for execution once this
Promise has completed, and returns a new Promise
representing the outcome of the invoked function. |
<VOUT,EOUT extends Exception> |
PromiseImpl.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException,
AsyncFunction<? super RuntimeException,VOUT,EOUT> onRuntimeException) |
<VOUT,EOUT extends Exception> |
PromiseImpl.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException,
AsyncFunction<? super RuntimeException,VOUT,EOUT> onRuntimeException) |
<VOUT,EOUT extends Exception> |
PromiseImpl.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException,
AsyncFunction<? super RuntimeException,VOUT,EOUT> onRuntimeException) |
<VOUT,EOUT extends Exception> |
Promise.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException,
AsyncFunction<? super RuntimeException,VOUT,EOUT> onRuntimeException)
Submits the provided asynchronous functions for execution once this
Promise has completed, and returns a new Promise
representing the outcome of the invoked function. |
<VOUT,EOUT extends Exception> |
Promise.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException,
AsyncFunction<? super RuntimeException,VOUT,EOUT> onRuntimeException)
Submits the provided asynchronous functions for execution once this
Promise has completed, and returns a new Promise
representing the outcome of the invoked function. |
<VOUT,EOUT extends Exception> |
Promise.thenAsync(AsyncFunction<? super V,VOUT,EOUT> onResult,
AsyncFunction<? super E,VOUT,EOUT> onException,
AsyncFunction<? super RuntimeException,VOUT,EOUT> onRuntimeException)
Submits the provided asynchronous functions for execution once this
Promise has completed, and returns a new Promise
representing the outcome of the invoked function. |
<EOUT extends Exception> |
PromiseImpl.thenCatchAsync(AsyncFunction<? super E,V,EOUT> onException) |
<EOUT extends Exception> |
Promise.thenCatchAsync(AsyncFunction<? super E,V,EOUT> onException)
Submits the provided asynchronous function for execution once this
Promise has completed with an exception, and returns a new
Promise representing the outcome of the function. |
Promise<V,E> |
PromiseImpl.thenCatchRuntimeExceptionAsync(AsyncFunction<? super RuntimeException,V,E> onRuntimeException) |
Promise<V,E> |
Promise.thenCatchRuntimeExceptionAsync(AsyncFunction<? super RuntimeException,V,E> onRuntimeException)
Submits the provided asynchronous function for execution once this
Promise has completed with a RuntimeException , and returns a new
Promise representing the outcome of the function. |
Copyright 2011-2015 ForgeRock AS.