Package com.zendesk.maxwell.producer

Class BufferedProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.BufferedProducer

public class BufferedProducer
extends AbstractProducer

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
BufferedProducer(MaxwellContext context, int maxSize)

Method Summary

Modifier and Type	Method	Description
RowMap	poll(long timeout, TimeUnit unit)
void	push(RowMap r)

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

BufferedProducer

public BufferedProducer(MaxwellContext context,
                        int maxSize)

Method Detail

push

public void push(RowMap r)
          throws Exception

Specified by:

push in class AbstractProducer

Throws:

Exception

poll

public RowMap poll(long timeout,
                   TimeUnit unit)
            throws InterruptedException

Throws:

InterruptedException