Modifier and Type | Method and Description |
---|---|
Future<?> |
AsyncCancellationClient.serviceAsync(Barrier barrier,
AtomicBoolean wasInterrupted) |
Future<?> |
AsyncCancellationClient.serviceAsyncBulkhead(Barrier barrier) |
Future<?> |
AsyncCancellationClient.serviceAsyncRetry(Barrier barrier) |
Modifier and Type | Method and Description |
---|---|
static void |
BulkheadSynchTest.testBulkhead(int maxRunning,
Consumer<Barrier> bulkheadMethod)
Conducts a standard test to ensure that a synchronous bulkhead with no
other annotations works correctly.
|
static void |
BulkheadAsynchTest.testBulkhead(int maxRunning,
int maxQueued,
Function<Barrier,Future<?>> bulkheadMethod)
Conducts a standard test to ensure that an asynchronous bulkhead with no
other annotations works correctly.
|
Modifier and Type | Method and Description |
---|---|
void |
BulkheadRetryAbortOnSyncBean.test(Barrier barrier) |
Future<?> |
BulkheadRetryAbortOnAsyncBean.test(Barrier barrier) |
void |
BulkheadMethodSemaphoreDefaultBean.test(Barrier barrier) |
Future<?> |
BulkheadMethodAsynchronousQueueingBean.test(Barrier barrier) |
Future<?> |
BulkheadMethodAsynchronousDefaultBean.test(Barrier barrier) |
void |
BulkheadClassSemaphoreDefaultBean.test(Barrier barrier) |
Future<?> |
BulkheadClassAsynchronousQueueingBean.test(Barrier barrier) |
Future<?> |
BulkheadClassAsynchronousDefaultBean.test(Barrier barrier) |
Future<?> |
Bulkhead55RapidRetry10MethodAsynchBean.test(Barrier barrier) |
Future<?> |
Bulkhead55RapidRetry10ClassAsynchBean.test(Barrier barrier) |
void |
Bulkhead3TaskQueueSemaphoreBean.test(Barrier barrier) |
void |
Bulkhead3MethodSemaphoreBean.test(Barrier barrier) |
Future<?> |
Bulkhead3MethodAsynchronousBean.test(Barrier barrier) |
void |
Bulkhead3ClassSemaphoreBean.test(Barrier barrier) |
Future<?> |
Bulkhead3ClassAsynchronousBean.test(Barrier barrier) |
Future<?> |
Bulkhead33RetryManyAsyncMethodBean.test(Barrier barrier) |
Future<?> |
Bulkhead33RetryManyAsyncClassBean.test(Barrier barrier) |
void |
Bulkhead1RetryManySyncMethodBean.test(Barrier barrier) |
void |
Bulkhead1RetryManySyncClassBean.test(Barrier barrier) |
void |
Bulkhead1Retry0MethodSyncBean.test(Barrier barrier) |
void |
Bulkhead10MethodSemaphoreBean.test(Barrier barrier) |
Future<?> |
Bulkhead10MethodAsynchronousBean.test(Barrier barrier) |
void |
Bulkhead10ClassSemaphoreBean.test(Barrier barrier) |
Future<?> |
Bulkhead10ClassAsynchronousBean.test(Barrier barrier) |
Future<?> |
BulkheadRetryQueueAsyncBean.test(Barrier barrier,
RuntimeException ex) |
Future<?> |
BulkheadRetryDelayAsyncBean.test(Barrier barrier,
RuntimeException e) |
void |
Bulkhead1Retry1SyncMethodBean.test(Barrier barrier,
RuntimeException ex) |
void |
Bulkhead1Retry1SyncClassBean.test(Barrier barrier,
RuntimeException ex) |
Future<String> |
BulkheadFutureMethodBean.test(Future<String> result,
Barrier barrier) |
Future<String> |
BulkheadFutureClassBean.test(Future<String> result,
Barrier barrier) |
Modifier and Type | Method and Description |
---|---|
void |
BulkheadLifecycleServiceSuperclass.service(Barrier barrier) |
void |
BulkheadLifecycleService2.service(Barrier barrier) |
void |
BulkheadLifecycleService1.service(Barrier barrier) |
void |
MutlipleMethodsBulkheadLifecycleService.service1(Barrier barrier) |
void |
MutlipleMethodsBulkheadLifecycleService.service2(Barrier barrier) |
Modifier and Type | Method and Description |
---|---|
Future<?> |
CircuitBreakerClientWithSyncBulkhead.test(Barrier barrier) |
Future<?> |
CircuitBreakerClientWithAsyncBulkheadNoFail.test(Barrier barrier) |
Future<?> |
CircuitBreakerClientWithAsyncBulkhead.test(Barrier barrier) |
Modifier and Type | Method and Description |
---|---|
void |
BulkheadConfigBean.serviceValue(Barrier barrier) |
Future<Void> |
BulkheadConfigBean.serviceWaitingTaskQueue(Barrier barrier) |
Modifier and Type | Method and Description |
---|---|
Barrier |
AsyncTaskManager.newBarrier()
Create a
Barrier not associated with any task |
Modifier and Type | Method and Description |
---|---|
static void |
Barrier.assertAllNotAwaiting(Collection<? extends Barrier> barriers)
Assert that no task waits on any of a set of barriers within EXPECTED_FAIL_TIME_MS
|
<T> AsyncTaskManager.BarrierTask<T> |
AsyncTaskManager.runAsyncBarrierTask(Function<Barrier,Future<? extends T>> task)
Run an asynchronous task which awaits a barrier
|
<T> AsyncTaskManager.BarrierTask<T> |
AsyncTaskManager.runAsyncCsBarrierTask(Function<Barrier,CompletionStage<? extends T>> task)
Run an asynchronous task which awaits a barrier
|
AsyncTaskManager.BarrierTask<Void> |
AsyncTaskManager.runBarrierTask(Consumer<Barrier> task)
Run a task which awaits on a barrier
|
Constructor and Description |
---|
BarrierTask(Future<? extends T> result,
Barrier barrier) |
Copyright © 2020 Eclipse Foundation. All rights reserved.