Package com.sankcrm.erp.contract.event

Class OnContractAuthSuccessEvent.FaceVideoListener

java.lang.Object

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

com.sankcrm.erp.contract.event.OnContractAuthSuccessEvent.FaceVideoListener

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:

OnContractAuthSuccessEvent

@Component("faceVideoListenContractAuthSuccessEvent")
public static class OnContractAuthSuccessEvent.FaceVideoListener
extends com.sankcrm.erp.kafka.consumer.event.AbstractEventListener<ContractAuthSuccessEvent>

Constructor Summary

Constructors

Constructor	Description
FaceVideoListener(OnContractAuthSuccessEvent.FaceVideoHandler 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

FaceVideoListener

public FaceVideoListener(OnContractAuthSuccessEvent.FaceVideoHandler handler,
 com.sankcrm.erp.bus.Bus bus)

Method Details

onMessage

@KafkaListener(id="contract.auth.face.video",
               topics="#{T(com.sankcrm.erp.contract.event.OnContractAuthSuccessEvent).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<ContractAuthSuccessEvent>