public class AmazonSQSRemoteMessageDispatcherFactory extends AbstractMessageDispatcherFactory<String>
Constructor and Description |
---|
AmazonSQSRemoteMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Destroy.
|
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
String topic,
T message) |
org.osgi.framework.BundleContext |
getBundleContext() |
String |
getMetricDomain() |
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) |
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getMetrics, getModuleMetadata, onDestroy, onInit
public AmazonSQSRemoteMessageDispatcherFactory()
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, String topic, T message)
dispatch
in class AbstractMessageDispatcherFactory<String>
public void init() throws IOException
IOException
- Signals that an I/O exception has occurred.public void destroy()
public String getMetricDomain()
getMetricDomain
in class AbstractMessageDispatcherFactory<String>
public org.osgi.framework.BundleContext getBundleContext()
getBundleContext
in class AbstractMessageDispatcherFactory<String>
public io.opentracing.Tracer getTracer()
getTracer
in class AbstractMessageDispatcherFactory<String>
public void setAwsSqsManager(AmazonSQSManager awsSqsManager)
awsSqsManager
- the new AWS SQS managerpublic void setBundleContext(org.osgi.framework.BundleContext bundleContext)
Copyright © 2020. All rights reserved.