Package com.sankcrm.erp.apisix.aliyun.event

Class OnTLSCertDNSInitEvent.Listener

java.lang.Object

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

com.sankcrm.erp.apisix.aliyun.event.OnTLSCertDNSInitEvent.Listener

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>

Enclosing interface:

OnTLSCertDNSInitEvent

@Component("aliConfTestListenTLSCertDNSInitEvent")
public static class OnTLSCertDNSInitEvent.Listener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<TLSCertDNSInitEvent>

Constructor Summary

Constructors

Constructor	Description
Listener(OnTLSCertDNSInitEvent.Handler handler)

Method Summary

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

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

Listener

public Listener(OnTLSCertDNSInitEvent.Handler handler)

Method Details

onMessage

@KafkaListener(id="ali.conf.dns.init",
               topics="#{T(com.sankcrm.erp.apisix.aliyun.event.OnTLSCertDNSInitEvent).topic()}")
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<TLSCertDNSInitEvent>