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

Class OnContractSignatoryCreatedEvent.ToAuthListener

java.lang.Object

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

com.sankcrm.erp.contract.event.signatory.OnContractSignatoryCreatedEvent.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:

OnContractSignatoryCreatedEvent

@Component("toAuthListenContractSignatoryCreatedEvent")
public static class OnContractSignatoryCreatedEvent.ToAuthListener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<ContractSignatoryCreatedEvent>

Constructor Summary

Constructors

Constructor	Description
ToAuthListener(OnContractSignatoryCreatedEvent.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(OnContractSignatoryCreatedEvent.ToAuthHandler handler,
 com.sankcrm.erp.bus.Bus bus)

Method Details

onMessage

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