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

Class RocketMQConsumerFactory

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.integration.inbound.RocketMQConsumerFactory

public final class RocketMQConsumerFactory
extends Object

Extended function related to producer . eg:initial

Author:

zkzlx

Method Summary

Modifier and Type	Method	Description
static org.apache.rocketmq.client.consumer.DefaultLitePullConsumer	initPullConsumer(String topic, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> extendedConsumerProperties)	todo Compatible with versions less than 4.6 ?
static org.apache.rocketmq.client.consumer.DefaultMQPushConsumer	initPushConsumer(org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> extendedConsumerProperties)

Methods inherited from class java.lang.Object

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

Method Details

initPushConsumer

public static org.apache.rocketmq.client.consumer.DefaultMQPushConsumer initPushConsumer(org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> extendedConsumerProperties)

initPullConsumer

public static org.apache.rocketmq.client.consumer.DefaultLitePullConsumer initPullConsumer(String topic,
 org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> extendedConsumerProperties)

todo Compatible with versions less than 4.6 ?

Parameters:

topic - consumer topic.

extendedConsumerProperties - extendedConsumerProperties

Returns:

DefaultLitePullConsumer