Package com.alibaba.cloud.stream.binder.rocketmq.integration.outbound

Class RocketMQProduceFactory

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.integration.outbound.RocketMQProduceFactory

public final class RocketMQProduceFactory
extends Object

Extended function related to producer . eg:initial .

Author:

zkzlx

Method Summary

Modifier and Type	Method	Description
static org.apache.rocketmq.client.producer.DefaultMQProducer	initRocketMQProducer(String topic, RocketMQProducerProperties producerProperties)	init for the producer,including convert producer params.

Methods inherited from class java.lang.Object

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

Method Details

initRocketMQProducer

public static org.apache.rocketmq.client.producer.DefaultMQProducer initRocketMQProducer(String topic,
 RocketMQProducerProperties producerProperties)

init for the producer,including convert producer params.

Parameters:

topic - topic

producerProperties - producerProperties

Returns:

DefaultMQProducer