Modifier and Type | Method and Description |
---|---|
TracerRegistry |
KafkaRpcClientFactory.getTracerRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
KafkaRpcClientFactory.setTracerRegistry(TracerRegistry tracerRegistry) |
Constructor and Description |
---|
KafkaRpcServerManager(KafkaConfigProvider configProvider,
MinionIdentity minionIdentity,
TracerRegistry tracerRegistry) |
Modifier and Type | Method and Description |
---|---|
TracerRegistry |
CamelRemoteMessageDispatcherFactory.getTracerRegistry() |
TracerRegistry |
CamelLocalMessageDispatcherFactory.getTracerRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
CamelRemoteMessageDispatcherFactory.setTracerRegistry(TracerRegistry tracerRegistry) |
void |
CamelLocalMessageDispatcherFactory.setTracerRegistry(TracerRegistry tracerRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
CamelMessageConsumerManager.setTracerRegistry(TracerRegistry tracerRegistry) |
Constructor and Description |
---|
CamelMessageConsumerManager(org.apache.camel.CamelContext context,
Identity identity,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
CamelSinkServerProcessor(CamelMessageConsumerManager consumerManager,
SinkModule<?,Message> module,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
TracerRegistry |
KafkaRemoteMessageDispatcherFactory.getTracerRegistry() |
TracerRegistry |
KafkaLocalMessageDispatcherFactory.getTracerRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
KafkaRemoteMessageDispatcherFactory.setTracerRegistry(TracerRegistry tracerRegistry) |
void |
KafkaLocalMessageDispatcherFactory.setTracerRegistry(TracerRegistry tracerRegistry) |
Modifier and Type | Method and Description |
---|---|
TracerRegistry |
KafkaMessageConsumerManager.getTracerRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
KafkaMessageConsumerManager.setTracerRegistry(TracerRegistry tracerRegistry) |
Constructor and Description |
---|
KafkaMessageConsumerManager(KafkaConfigProvider configProvider,
Identity identity,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
Constructor and Description |
---|
AmazonSQSServerProcessor(RpcModule<RpcRequest,RpcResponse> module,
TracerRegistry tracerRegistry) |
AmazonSQSServerRouteManager(org.apache.camel.CamelContext context,
MinionIdentity identity,
AmazonSQSManager sqsManager,
TracerRegistry tracerRegistry) |
Modifier and Type | Method and Description |
---|---|
TracerRegistry |
CamelRpcClientFactory.getTracerRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
CamelRpcClientFactory.setTracerRegistry(TracerRegistry tracerRegistry) |
Constructor and Description |
---|
CamelRpcServerProcessor(RpcModule<RpcRequest,RpcResponse> module,
TracerRegistry tracerRegistry) |
Constructor and Description |
---|
JmsRpcServerRouteManager(org.apache.camel.CamelContext context,
MinionIdentity identity,
TracerRegistry tracerRegistry) |
Modifier and Type | Class and Description |
---|---|
class |
TracerRegistryImpl
Implements TracerRegistry and provides onBind, OnUnbind for
TracerWrapper to get registered from osgi registry. |
Modifier and Type | Method and Description |
---|---|
TracerRegistry |
ElasticFlowRepository.getTracerRegistry() |
Constructor and Description |
---|
ElasticFlowRepository(com.codahale.metrics.MetricRegistry metricRegistry,
io.searchbox.client.JestClient jestClient,
IndexStrategy indexStrategy,
DocumentEnricher documentEnricher,
ClassificationEngine classificationEngine,
SessionUtils sessionUtils,
NodeDao nodeDao,
SnmpInterfaceDao snmpInterfaceDao,
Identity identity,
TracerRegistry tracerRegistry,
IndexSettings indexSettings,
int bulkRetryCount,
long maxFlowDurationMs) |
Copyright © 2020. All rights reserved.