Package com.zendesk.maxwell.producer

Class AbstractAsyncProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.AbstractAsyncProducer

Direct Known Subclasses:

MaxwellKinesisProducer, MaxwellSNSProducer, MaxwellSQSProducer

public abstract class AbstractAsyncProducer
extends AbstractProducer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	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
AbstractAsyncProducer(MaxwellContext context)

Method Summary

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

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

AbstractAsyncProducer

public AbstractAsyncProducer(MaxwellContext context)

Method Detail

sendAsync

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

Throws:

Exception

push

public final void push(RowMap r)
                throws Exception

Specified by:

push in class AbstractProducer

Throws:

Exception