|
|
|
@@ -27,7 +27,7 @@ import com.iformall.utils.JsonUtil; |
|
|
|
* @Date: 2019-01-31 |
|
|
|
* @Description: RocketMQ消息生产者 |
|
|
|
*/ |
|
|
|
//@Service |
|
|
|
@Service |
|
|
|
@Profile(MQConfig.Impl.ALIYUN_ROCKET_MQ) |
|
|
|
public class AliyunRocketMqMessageProducer implements MqBaseProducer { |
|
|
|
private final Logger log = LoggerFactory.getLogger(this.getClass()); |
|
|
|
@@ -53,7 +53,7 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer { |
|
|
|
|
|
|
|
private static Producer producer = null; |
|
|
|
|
|
|
|
// @PostConstruct |
|
|
|
@PostConstruct |
|
|
|
public void init() { |
|
|
|
Properties properties = new Properties(); |
|
|
|
properties.setProperty(PropertyKeyConst.GROUP_ID, groupId); |
|
|
|
|