19 lines
458 B
Java
19 lines
458 B
Java
|
package com.gzzn.omms.msgexchangeapi.service;
|
||
|
|
|
||
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
||
|
|
import org.springframework.kafka.core.KafkaTemplate;
|
||
|
|
import org.springframework.stereotype.Service;
|
||
|
|
|
||
|
|
@Service
|
||
|
|
public class KafkaServiceImpl implements IKafkaService{
|
||
|
|
|
||
|
|
@Autowired
|
||
|
|
private KafkaTemplate kafkaTemplate;
|
||
|
|
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public void msgSend(String topic, String msg) {
|
||
|
|
kafkaTemplate.send(topic, msg);
|
||
|
|
}
|
||
|
|
}
|