Package com.zendesk.maxwell.producer

Class MaxwellSNSProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.AbstractAsyncProducer

com.zendesk.maxwell.producer.MaxwellSNSProducer

public class MaxwellSNSProducer
extends AbstractAsyncProducer

Nested Class Summary

Nested classes/interfaces inherited from class com.zendesk.maxwell.producer.AbstractAsyncProducer

AbstractAsyncProducer.CallbackCompleter

Field Summary

Fields inherited from class com.zendesk.maxwell.producer.AbstractProducer

context, failedMessageCount, failedMessageMeter, messageLatencySloViolationCount, messageLatencyTimer, messagePublishTimer, outputConfig, succeededMessageCount, succeededMessageMeter

Constructor Summary

Constructors

Constructor	Description
MaxwellSNSProducer(MaxwellContext context, String topic)

Method Summary

Modifier and Type	Method	Description
void	sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)
void	setClient(com.amazonaws.services.sns.AmazonSNSAsync client)

Methods inherited from class com.zendesk.maxwell.producer.AbstractAsyncProducer

push

Methods inherited from class com.zendesk.maxwell.producer.AbstractProducer

getDiagnostic, getFailedMessageMeter, getStoppableTask

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxwellSNSProducer

public MaxwellSNSProducer(MaxwellContext context,
                          String topic)

Method Detail

setClient

public void setClient(com.amazonaws.services.sns.AmazonSNSAsync client)

sendAsync

public void sendAsync(RowMap r,
                      AbstractAsyncProducer.CallbackCompleter cc)
               throws Exception

Specified by:

sendAsync in class AbstractAsyncProducer

Throws:

Exception