Package io.aiven.kafka.connect.amqp.source

Class AmqpOffsetManagerEntry

java.lang.Object

io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

All Implemented Interfaces:

io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

public final class AmqpOffsetManagerEntry
extends Object
implements io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

The OffsetManager Entry for the AMQP messages

Method Summary

Modifier and Type	Method	Description
AmqpOffsetManagerEntry	fromProperties(Map<String,Object> properties)
io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerKey	getManagerKey()
Map<String,Object>	getProperties()
Object	getProperty(String key)
long	getRecordCount()
void	incrementRecordCount()
void	setProperty(String key, Object value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

getInt, getLong, getString

Method Details

fromProperties

public AmqpOffsetManagerEntry fromProperties(Map<String,Object> properties)

Specified by:

fromProperties in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

getProperties

public Map<String,Object> getProperties()

Specified by:

getProperties in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

getProperty

public Object getProperty(String key)

Specified by:

getProperty in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

setProperty

public void setProperty(String key,
 Object value)

Specified by:

setProperty in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

getManagerKey

public io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerKey getManagerKey()

Specified by:

getManagerKey in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

incrementRecordCount

public void incrementRecordCount()

Specified by:

incrementRecordCount in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry

getRecordCount

public long getRecordCount()

Specified by:

getRecordCount in interface io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry