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

Class AmazonSQSRemoteMessageDispatcherFactory

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory<java.lang.String>

org.opennms.core.ipc.sink.aws.sqs.client.AmazonSQSRemoteMessageDispatcherFactory

All Implemented Interfaces:

MessageDispatcherFactory

public class AmazonSQSRemoteMessageDispatcherFactory
extends AbstractMessageDispatcherFactory<java.lang.String>

A factory for creating AwsRemoteMessageDispatcher objects.

Author:

Alejandro Galue

Constructor Summary

Constructors

Constructor	Description
AmazonSQSRemoteMessageDispatcherFactory()

Method Summary

Modifier and Type	Method	Description
void	destroy()	Destroy.
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, java.lang.String topic, T message)
org.osgi.framework.BundleContext	getBundleContext()
java.lang.String	getMetricDomain()
com.codahale.metrics.MetricRegistry	getMetrics()
io.opentracing.Tracer	getTracer()
void	init()	Initializes the producers.
void	setAwsSqsManager(AmazonSQSManager awsSqsManager)	Sets the AWS SQS manager.
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setMetrics(com.codahale.metrics.MetricRegistry metrics)

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

createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getModuleMetadata, onDestroy, onInit

Methods inherited from class java.lang.Object

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

Constructor Detail

AmazonSQSRemoteMessageDispatcherFactory

public AmazonSQSRemoteMessageDispatcherFactory()

Method Detail

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                                 java.lang.String topic,
                                                                 T message)

Specified by:

dispatch in class AbstractMessageDispatcherFactory<java.lang.String>

init

public void init()
          throws java.io.IOException

Initializes the producers.

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

destroy

public void destroy()

Destroy.

getMetricDomain

public java.lang.String getMetricDomain()

Specified by:

getMetricDomain in class AbstractMessageDispatcherFactory<java.lang.String>

getBundleContext

public org.osgi.framework.BundleContext getBundleContext()

Specified by:

getBundleContext in class AbstractMessageDispatcherFactory<java.lang.String>

getTracer

public io.opentracing.Tracer getTracer()

Specified by:

getTracer in class AbstractMessageDispatcherFactory<java.lang.String>

setAwsSqsManager

public void setAwsSqsManager(AmazonSQSManager awsSqsManager)

Sets the AWS SQS manager.

Parameters:

awsSqsManager - the new AWS SQS manager

setBundleContext

public void setBundleContext(org.osgi.framework.BundleContext bundleContext)

getMetrics

public com.codahale.metrics.MetricRegistry getMetrics()

Specified by:

getMetrics in class AbstractMessageDispatcherFactory<java.lang.String>

setMetrics

public void setMetrics(com.codahale.metrics.MetricRegistry metrics)