wang.bigbird.domain.framework.data.rocketmq.base.helper

类 MQProducerHelper

java.lang.Object

wang.bigbird.domain.framework.data.rocketmq.base.helper.MQProducerHelper

public class MQProducerHelper
extends Object

消息生产者创建器

作者:

Bigbird

构造器概要

构造器

构造器和说明
MQProducerHelper()

方法概要

限定符和类型	方法和说明
static org.apache.rocketmq.client.producer.DefaultMQProducer	createDefaultMQProducer(String producerGroupName, RocketmqProducerProperties rocketmqProducerProperties) 创建消息生产者

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MQProducerHelper

public MQProducerHelper()

方法详细资料

createDefaultMQProducer

public static org.apache.rocketmq.client.producer.DefaultMQProducer createDefaultMQProducer(String producerGroupName,
                                                                                            RocketmqProducerProperties rocketmqProducerProperties)

创建消息生产者

参数:

producerGroupName - 生产者组名，组的意义在于集群模式下，当一个节点挂掉，可以依靠组内其他节点继续工作。

rocketmqProducerProperties - 生产者配置属性

返回:

消息生产者