Package org.opennms.core.ipc.sink.aws.sqs.server

Class AmazonSQSMessageConsumerManager

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager

org.opennms.core.ipc.sink.aws.sqs.server.AmazonSQSMessageConsumerManager

All Implemented Interfaces:

MessageConsumerManager

public class AmazonSQSMessageConsumerManager
extends AbstractMessageConsumerManager

The Class AwsMessageConsumerManager.

Author:

Alejandro Galue

Field Summary

Fields inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager

SINK_INITIAL_SLEEP_TIME, startupExecutor, waitForStartup

Fields inherited from interface org.opennms.core.ipc.sink.api.MessageConsumerManager

LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED

Constructor Summary

Constructors

Constructor	Description
AmazonSQSMessageConsumerManager()

Method Summary

Modifier and Type	Method	Description
void	setAwsSqsManager(AmazonSQSManager awsSqsManager)	Sets the AWS SQS manager.
void	shutdown()
protected void	startConsumingForModule(SinkModule<?,Message> module)
protected void	stopConsumingForModule(SinkModule<?,Message> module)

Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager

dispatch, getNumConsumerThreads, getStartupExecutor, registerConsumer, unregisterAllConsumers, unregisterConsumer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmazonSQSMessageConsumerManager

public AmazonSQSMessageConsumerManager()

Method Detail

setAwsSqsManager

public void setAwsSqsManager(AmazonSQSManager awsSqsManager)

Sets the AWS SQS manager.

Parameters:

awsSqsManager - the new AWS SQS manager

startConsumingForModule

protected void startConsumingForModule(SinkModule<?,Message> module)
                                throws java.lang.Exception

Specified by:

startConsumingForModule in class AbstractMessageConsumerManager

Throws:

java.lang.Exception

stopConsumingForModule

protected void stopConsumingForModule(SinkModule<?,Message> module)
                               throws java.lang.Exception

Specified by:

stopConsumingForModule in class AbstractMessageConsumerManager

Throws:

java.lang.Exception

shutdown

public void shutdown()