Package com.zendesk.maxwell.producer

Class InflightMessageList

java.lang.Object

com.zendesk.maxwell.producer.InflightMessageList

public class InflightMessageList
extends Object

Constructor Summary

Constructors

Constructor	Description
InflightMessageList(MaxwellContext context)
InflightMessageList(MaxwellContext context, int capacity)

Method Summary

Modifier and Type	Method	Description
void	addMessage(Position p, long eventTimestampMillis, long messageID)
com.zendesk.maxwell.producer.InflightMessageList.InflightMessage	completeMessage(Position p)
void	freeSlot(long messageID)
int	size()
long	waitForSlot()

Methods inherited from class java.lang.Object

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

Constructor Detail

InflightMessageList

public InflightMessageList(MaxwellContext context)

InflightMessageList

public InflightMessageList(MaxwellContext context,
                           int capacity)

Method Detail

waitForSlot

public long waitForSlot()
                 throws InterruptedException

Throws:

InterruptedException

freeSlot

public void freeSlot(long messageID)

addMessage

public void addMessage(Position p,
                       long eventTimestampMillis,
                       long messageID)
                throws InterruptedException

Throws:

InterruptedException

completeMessage

public com.zendesk.maxwell.producer.InflightMessageList.InflightMessage completeMessage(Position p)

size

public int size()