public class AmazonSQSMessageConsumerManager extends AbstractMessageConsumerManager
SINK_INITIAL_SLEEP_TIME, waitForStartup
LOG_PREFIX
Constructor and Description |
---|
AmazonSQSMessageConsumerManager() |
Modifier and Type | Method and Description |
---|---|
void |
setAwsSqsManager(AmazonSQSManager awsSqsManager)
Sets the AWS SQS manager.
|
protected void |
startConsumingForModule(SinkModule<?,Message> module) |
protected void |
stopConsumingForModule(SinkModule<?,Message> module) |
dispatch, getNumConsumerThreads, registerConsumer, unregisterAllConsumers, unregisterConsumer
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
Copyright © 2018. All rights reserved.