Modifier and Type | Method and Description |
---|---|
<T,A> Result<T,A> |
ExtensionsClient.execute(String extension,
String operation,
OperationParameters parameters)
Executes an operation synchronously and returns a
Result with the operation's output and attributes if available. |
Modifier and Type | Method and Description |
---|---|
<T,A> CompletableFuture<Result<T,A>> |
ExtensionsClient.executeAsync(String extension,
String operation,
OperationParameters parameters)
Executes an operation asynchronously by returning a
CompletableFuture instance that will complete into a
Result with the corresponding payload and attributes after the operation execution finished. |
Modifier and Type | Method and Description |
---|---|
Result<T,A> |
Result.Builder.build() |
Modifier and Type | Method and Description |
---|---|
void |
CompletionCallback.success(Result<T,A> result)
This method is to be invoked with the operation's result.
|
Modifier and Type | Method and Description |
---|---|
void |
Chain.process(Result input,
Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
|
Modifier and Type | Method and Description |
---|---|
void |
Chain.process(Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
Executes the chain of components starting with the same input message that it's container scope received.
|
void |
Chain.process(Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
Executes the chain of components starting with the same input message that it's container scope received.
|
void |
Chain.process(Object payload,
Object attributes,
Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
|
void |
Chain.process(Object payload,
Object attributes,
Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
|
void |
Chain.process(Result input,
Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
|
void |
Chain.process(Result input,
Consumer<Result> onSuccess,
BiConsumer<Throwable,Result> onError)
|
Modifier and Type | Method and Description |
---|---|
void |
SourceCallback.handle(Result<T,A> result)
Passes the given
result back to the runtime for processing. |
void |
SourceCallback.handle(Result<T,A> result,
SourceCallbackContext context)
Passes the given
result back to the runtime for processing. |
abstract void |
PollingSource.onRejectedItem(Result<T,A> result,
SourceCallbackContext callbackContext)
If one of the items dispatched through
PollContext.accept(Consumer) were rejected (either by watermarking,
idempotency, server overload, etc.), this method is to be used to released any resources associated to the given
result . |
PollContext.PollItem<T,A> |
PollContext.PollItem.setResult(Result<T,A> result)
Sets the item content in the form of a
Result |
Modifier and Type | Class and Description |
---|---|
class |
EventedResult<T,A>
|
Modifier and Type | Method and Description |
---|---|
Result<SoapOutputPayload,SoapAttributes> |
SoapResponse.getAsResult(StreamingHelper helper) |
Copyright © 2018. All rights reserved.