@Configuration
@ConditionalOnProperty(name="log-record.data-pipeline",
havingValue="rocketMq")
@EnableConfigurationProperties(value=LogRecordProperties.class)
public class RocketMqSenderConfiguration
extends Object
@PostConstruct public void rabbitMqConfig()
@Bean
public org.apache.rocketmq.client.producer.DefaultMQProducer defaultMqProducer()
throws RuntimeException
RuntimeExceptionCopyright © 2023. All rights reserved.