Package com.sankcrm.erp.contract.event.signatory

Class OnContractSignatoryAuthCheckEvent.ToAuthListener

java.lang.Object

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

com.sankcrm.erp.contract.event.signatory.OnContractSignatoryAuthCheckEvent.ToAuthListener

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:

OnContractSignatoryAuthCheckEvent

@Component("listenContractSignatoryAuthCheckEvent")
public static class OnContractSignatoryAuthCheckEvent.ToAuthListener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<ContractSignatoryAuthCheckEvent>

Constructor Summary

Constructors

Constructor	Description
ToAuthListener(OnContractSignatoryAuthCheckEvent.ToAuthHandler 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)

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

ToAuthListener

public ToAuthListener(OnContractSignatoryAuthCheckEvent.ToAuthHandler handler,
 com.sankcrm.erp.bus.Bus bus)

Method Details

onMessage

@KafkaListener(id="contract.signatory.auth.check",
               topics="#{T(com.sankcrm.erp.contract.event.signatory.OnContractSignatoryAuthCheckEvent).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<ContractSignatoryAuthCheckEvent>