Package com.zendesk.maxwell.producer

Class AbstractAsyncProducer.CallbackCompleter

java.lang.Object

com.zendesk.maxwell.producer.AbstractAsyncProducer.CallbackCompleter

Enclosing class:

AbstractAsyncProducer

public class AbstractAsyncProducer.CallbackCompleter
extends Object

Constructor Summary

Constructors

Constructor	Description
CallbackCompleter(InflightMessageList inflightMessages, Position position, boolean isTXCommit, MaxwellContext context, long messageID)

Method Summary

Modifier and Type	Method	Description
void	markCompleted()

Methods inherited from class java.lang.Object

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

Constructor Detail

CallbackCompleter

public CallbackCompleter(InflightMessageList inflightMessages,
                         Position position,
                         boolean isTXCommit,
                         MaxwellContext context,
                         long messageID)

Method Detail

markCompleted

public void markCompleted()