Package com.sankcrm.erp.contract.event

Class OnContractSignedEvent.Listener

java.lang.Object

com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<com.sankcrm.erp.contract.event.ContractSignedEvent>

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

OnContractSignedEvent

@Component("caInfoListenContractSignedEvent")
public static class OnContractSignedEvent.Listener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<com.sankcrm.erp.contract.event.ContractSignedEvent>

Constructor Summary

Constructors

Constructor	Description
Listener(OnContractSignedEvent.Handler 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

Listener

public Listener(OnContractSignedEvent.Handler handler,
 com.sankcrm.erp.bus.Bus bus)

Method Details

onMessage

@KafkaListener(id="contract.signed.cainfo",
               topics="#{T(com.sankcrm.erp.contract.event.OnContractSignedEvent).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<com.sankcrm.erp.contract.event.ContractSignedEvent>