package com.java110.order.kaka;
|
|
import com.java110.core.base.AppBase;
|
import com.java110.order.smo.ICenterServiceSMO;
|
import com.java110.order.smo.IOrderServiceSMO;
|
import org.apache.kafka.clients.consumer.ConsumerRecord;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.kafka.annotation.KafkaListener;
|
|
/**
|
* kafka侦听
|
* Created by wuxw on 2018/4/15.
|
*/
|
public class CenserServiceKafkaListener extends AppBase {
|
|
protected final static Logger logger = LoggerFactory.getLogger(CenserServiceKafkaListener.class);
|
|
|
@Autowired
|
private IOrderServiceSMO orderServiceSMOImpl;
|
|
@KafkaListener(topics = {"NOTIFY_CENTER_SERVICE"})
|
public void listen(ConsumerRecord<?, ?> record) {
|
logger.info("kafka的key: " + record.key());
|
logger.info("kafka的value: " + record.value().toString());
|
orderServiceSMOImpl.receiveBusinessSystemNotifyMessage(record.value().toString());
|
}
|
|
|
public IOrderServiceSMO getOrderServiceSMOImpl() {
|
return orderServiceSMOImpl;
|
}
|
|
public void setOrderServiceSMOImpl(IOrderServiceSMO orderServiceSMOImpl) {
|
this.orderServiceSMOImpl = orderServiceSMOImpl;
|
}
|
}
|
