Package com.zendesk.maxwell.producer

Class MaxwellSQSProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.AbstractAsyncProducer

com.zendesk.maxwell.producer.MaxwellSQSProducer

public class MaxwellSQSProducer
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
MaxwellSQSProducer(MaxwellContext context, String queueUri, String serviceEndpoint, String signingRegion)

Method Summary

Modifier and Type	Method	Description
void	sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)

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

MaxwellSQSProducer

public MaxwellSQSProducer(MaxwellContext context,
                          String queueUri,
                          String serviceEndpoint,
                          String signingRegion)

Method Detail

sendAsync

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

Specified by:

sendAsync in class AbstractAsyncProducer

Throws:

Exception