Package com.sankcrm.area.event.changed

Class AreaChangedEventListener

java.lang.Object

com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<AreaChangedEvent>

com.sankcrm.area.event.changed.AreaChangedEventListener

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.kafka.listener.AcknowledgingMessageListener<String,String>, org.springframework.kafka.listener.GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>>, org.springframework.kafka.listener.MessageListener<String,String>

@Component("areaChangedEventListener")
public class AreaChangedEventListener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<AreaChangedEvent>

监听区域变更事件

Since:

2.0.0

Author:

zhsxin

create time:

2022/7/28 21:46

Constructor Summary

Constructors

Constructor	Description
AreaChangedEventListener(AreaChangedEventHandler handler, com.sankcrm.erp.bus.Bus bus)

Method Summary

Modifier and Type	Method	Description
void	onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record, org.springframework.kafka.support.Acknowledgment acknowledgment)
static String	topic()

Methods inherited from class com.sankcrm.erp.kafka.consumer.event.AbstractEventListener

onMessage, onMessage, onMessage, setBeanFactory

Methods inherited from class java.lang.Object

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

Constructor Details

AreaChangedEventListener

public AreaChangedEventListener(AreaChangedEventHandler handler,
 com.sankcrm.erp.bus.Bus bus)

Method Details

onMessage

@KafkaListener(id="area-changed-cache-${app.id}-${app.node:a}",
               topics="#{T(com.sankcrm.area.event.changed.AreaChangedEventListener).topic()}",
               concurrency="1")
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record,
 org.springframework.kafka.support.Acknowledgment acknowledgment)

Specified by:

onMessage in interface org.springframework.kafka.listener.AcknowledgingMessageListener<String,String>

Specified by:

onMessage in interface org.springframework.kafka.listener.GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>>

Overrides:

onMessage in class com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<AreaChangedEvent>

topic

public static String topic()