public interface MessageConsumerManager
Modifier and Type | Field and Description |
---|---|
static String |
LOG_PREFIX |
static String |
METRIC_DISPATCH_TIME |
static String |
METRIC_MESSAGE_SIZE |
static String |
METRIC_MESSAGES_RECEIVED |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
T message) |
static com.codahale.metrics.Timer |
getDispatchTimerMetric(com.codahale.metrics.MetricRegistry metricRegistry,
String location,
String moduleId) |
<S extends Message,T extends Message> |
registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
unregisterConsumer(MessageConsumer<S,T> consumer) |
static void |
updateMessageSize(com.codahale.metrics.MetricRegistry metricRegistry,
String location,
String moduleId,
int messageSize) |
static final String LOG_PREFIX
static final String METRIC_MESSAGES_RECEIVED
static final String METRIC_MESSAGE_SIZE
static final String METRIC_DISPATCH_TIME
<S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, T message)
<S extends Message,T extends Message> void registerConsumer(MessageConsumer<S,T> consumer) throws Exception
Exception
<S extends Message,T extends Message> void unregisterConsumer(MessageConsumer<S,T> consumer) throws Exception
Exception
static void updateMessageSize(com.codahale.metrics.MetricRegistry metricRegistry, String location, String moduleId, int messageSize)
Copyright © 2020. All rights reserved.