Package org.flowable.eventregistry.spring.kafka

Class KafkaChannelMessageListenerAdapter

java.lang.Object

org.flowable.eventregistry.spring.kafka.KafkaChannelMessageListenerAdapter

All Implemented Interfaces:

AcknowledgingConsumerAwareMessageListener<Object,Object>, GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object>>, MessageListener<Object,Object>

public class KafkaChannelMessageListenerAdapter
extends Object
implements AcknowledgingConsumerAwareMessageListener<Object,Object>

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected EventRegistry	eventRegistry
protected InboundChannelModel	inboundChannelModel

Constructor Summary

Constructors

Constructor	Description
KafkaChannelMessageListenerAdapter(EventRegistry eventRegistry, InboundChannelModel inboundChannelModel)

Method Summary

Modifier and Type	Method	Description
EventRegistry	getEventRegistry()
InboundChannelModel	getInboundChannelModel()
void	onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	setEventRegistry(EventRegistry eventRegistry)
void	setInboundChannelModel(InboundChannelModel inboundChannelModel)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener

onMessage

Methods inherited from interface org.springframework.kafka.listener.GenericMessageListener

onMessage, onMessage

Field Details

eventRegistry

protected EventRegistry eventRegistry

inboundChannelModel

protected InboundChannelModel inboundChannelModel

Constructor Details

KafkaChannelMessageListenerAdapter

public KafkaChannelMessageListenerAdapter(EventRegistry eventRegistry,
 InboundChannelModel inboundChannelModel)

Method Details

onMessage

public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object> data,
 Acknowledgment acknowledgment,
 org.apache.kafka.clients.consumer.Consumer<?,?> consumer)

Specified by:

onMessage in interface AcknowledgingConsumerAwareMessageListener<Object,Object>

Specified by:

onMessage in interface GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object>>

getEventRegistry

public EventRegistry getEventRegistry()

setEventRegistry

public void setEventRegistry(EventRegistry eventRegistry)

getInboundChannelModel

public InboundChannelModel getInboundChannelModel()

setInboundChannelModel

public void setInboundChannelModel(InboundChannelModel inboundChannelModel)