Package | Description |
---|---|
org.mule.runtime.extension.api.runtime.source |
Modifier and Type | Method and Description |
---|---|
SourceCallbackContext |
SourceCallback.createContext() |
SourceCallbackContext |
BackPressureContext.getSourceCallbackContext() |
SourceCallbackContext |
PollContext.PollItem.getSourceCallbackContext() |
SourceCallbackContext |
SourceResult.getSourceCallbackContext() |
Modifier and Type | Method and Description |
---|---|
void |
SourceCallback.handle(Result<T,A> result,
SourceCallbackContext context)
Passes the given
result back to the runtime for processing. |
static SourceResult |
SourceResult.invocationError(Error invocationError,
SourceCallbackContext sourceCallbackContext) |
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 . |
static SourceResult |
SourceResult.responseError(Error responseError,
SourceCallbackContext sourceCallbackContext) |
static SourceResult |
SourceResult.success(SourceCallbackContext sourceCallbackContext) |
Copyright © 2018. All rights reserved.