public final class ReactiveStreamsHelper extends Object
Modifier and Type | Method and Description |
---|---|
static DispatchCallback<org.apache.camel.Exchange> |
attachCallback(org.apache.camel.Exchange exchange,
DispatchCallback<org.apache.camel.Exchange> callback) |
static org.apache.camel.Exchange |
convertToExchange(org.apache.camel.CamelContext context,
Object data) |
static DispatchCallback<org.apache.camel.Exchange> |
detachCallback(org.apache.camel.Exchange exchange) |
static <T> T |
findInstance(org.apache.camel.CamelContext context,
String name,
Class<T> type) |
static DispatchCallback<org.apache.camel.Exchange> |
getCallback(org.apache.camel.Exchange exchange) |
static boolean |
invokeDispatchCallback(org.apache.camel.Exchange exchange) |
static boolean |
invokeDispatchCallback(org.apache.camel.Exchange exchange,
Throwable error) |
static CamelReactiveStreamsService |
resolveReactiveStreamsService(org.apache.camel.CamelContext context,
String serviceType,
ReactiveStreamsEngineConfiguration configuration)
Helper to lookup/create an instance of
CamelReactiveStreamsService |
static CamelReactiveStreamsServiceFactory |
resolveServiceFactory(org.apache.camel.CamelContext context,
String serviceType) |
public static DispatchCallback<org.apache.camel.Exchange> getCallback(org.apache.camel.Exchange exchange)
public static DispatchCallback<org.apache.camel.Exchange> attachCallback(org.apache.camel.Exchange exchange, DispatchCallback<org.apache.camel.Exchange> callback)
public static DispatchCallback<org.apache.camel.Exchange> detachCallback(org.apache.camel.Exchange exchange)
public static boolean invokeDispatchCallback(org.apache.camel.Exchange exchange)
public static boolean invokeDispatchCallback(org.apache.camel.Exchange exchange, Throwable error)
public static org.apache.camel.Exchange convertToExchange(org.apache.camel.CamelContext context, Object data)
public static <T> T findInstance(org.apache.camel.CamelContext context, String name, Class<T> type)
public static CamelReactiveStreamsService resolveReactiveStreamsService(org.apache.camel.CamelContext context, String serviceType, ReactiveStreamsEngineConfiguration configuration)
CamelReactiveStreamsService
public static CamelReactiveStreamsServiceFactory resolveServiceFactory(org.apache.camel.CamelContext context, String serviceType)
Apache Camel