public class AmazonSQSMessageConsumerManager extends AbstractMessageConsumerManager
SINK_INITIAL_SLEEP_TIME, startupExecutor, waitForStartup
LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED
Constructor and Description |
---|
AmazonSQSMessageConsumerManager() |
Modifier and Type | Method and Description |
---|---|
void |
setAwsSqsManager(AmazonSQSManager awsSqsManager)
Sets the AWS SQS manager.
|
void |
shutdown() |
protected void |
startConsumingForModule(SinkModule<?,Message> module) |
protected void |
stopConsumingForModule(SinkModule<?,Message> module) |
dispatch, getNumConsumerThreads, getStartupExecutor, registerConsumer, unregisterAllConsumers, unregisterConsumer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDispatchTimerMetric, updateMessageSize
public void setAwsSqsManager(AmazonSQSManager awsSqsManager)
awsSqsManager
- the new AWS SQS managerprotected void startConsumingForModule(SinkModule<?,Message> module) throws Exception
startConsumingForModule
in class AbstractMessageConsumerManager
Exception
protected void stopConsumingForModule(SinkModule<?,Message> module) throws Exception
stopConsumingForModule
in class AbstractMessageConsumerManager
Exception
public void shutdown()
Copyright © 2020. All rights reserved.