Package com.sankcrm.erp.apisix.event.tlscert.apply

Class OnTLSCertApplyChallengeReadyEvent.Listener

java.lang.Object

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

com.sankcrm.erp.apisix.event.tlscert.apply.OnTLSCertApplyChallengeReadyEvent.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:

OnTLSCertApplyChallengeReadyEvent

@Component("tlsCertApplyChallengeReadyEventListener")
public static class OnTLSCertApplyChallengeReadyEvent.Listener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<TLSCertApplyChallengeReadyEvent>

Constructor Summary

Constructors

Constructor	Description
Listener(OnTLSCertApplyChallengeReadyEvent.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(OnTLSCertApplyChallengeReadyEvent.Handler handler)

Method Details

onMessage

@KafkaListener(id="tls.cert.apply.challenge.ready",
               topics="#{T(com.sankcrm.erp.apisix.event.tlscert.apply.OnTLSCertApplyChallengeReadyEvent).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<TLSCertApplyChallengeReadyEvent>