public class CamelLocalMessageDispatcherFactory extends AbstractMessageDispatcherFactory<Void> implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean
Constructor and Description |
---|
CamelLocalMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
void |
destroy() |
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
org.osgi.framework.BundleContext |
getBundleContext() |
String |
getMetricDomain() |
com.codahale.metrics.MetricRegistry |
getMetrics() |
io.opentracing.Tracer |
getTracer() |
TracerRegistry |
getTracerRegistry() |
void |
setMetrics(com.codahale.metrics.MetricRegistry metrics) |
void |
setTracerRegistry(TracerRegistry tracerRegistry) |
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getModuleMetadata, onDestroy, onInit
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, Void metadata, T message)
dispatch
in class AbstractMessageDispatcherFactory<Void>
public String getMetricDomain()
getMetricDomain
in class AbstractMessageDispatcherFactory<Void>
public org.osgi.framework.BundleContext getBundleContext()
getBundleContext
in class AbstractMessageDispatcherFactory<Void>
public TracerRegistry getTracerRegistry()
public void setTracerRegistry(TracerRegistry tracerRegistry)
public io.opentracing.Tracer getTracer()
getTracer
in class AbstractMessageDispatcherFactory<Void>
public void afterPropertiesSet()
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
public void destroy()
destroy
in interface org.springframework.beans.factory.DisposableBean
public com.codahale.metrics.MetricRegistry getMetrics()
getMetrics
in class AbstractMessageDispatcherFactory<Void>
public void setMetrics(com.codahale.metrics.MetricRegistry metrics)
Copyright © 2020. All rights reserved.