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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Destroy.<S extends Message,T extends Message>
voiddispatch(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
-
-
-
-
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 classAbstractMessageDispatcherFactory<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 classAbstractMessageDispatcherFactory<java.lang.String>
-
getBundleContext
public org.osgi.framework.BundleContext getBundleContext()
- Specified by:
getBundleContext
in classAbstractMessageDispatcherFactory<java.lang.String>
-
getTracer
public io.opentracing.Tracer getTracer()
- Specified by:
getTracer
in classAbstractMessageDispatcherFactory<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 classAbstractMessageDispatcherFactory<java.lang.String>
-
setMetrics
public void setMetrics(com.codahale.metrics.MetricRegistry metrics)
-
-