Package com.alibaba.cloud.stream.binder.rocketmq.utils

Class RocketMQUtils

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.utils.RocketMQUtils

public final class RocketMQUtils
extends Object

Author:

Jim

Method Summary

Modifier and Type	Method	Description
static String	anonymousGroup(String destination)	generate anonymous group.
static String	getInstanceName(org.apache.rocketmq.remoting.RPCHook rpcHook, String identify)
static org.apache.rocketmq.client.consumer.MessageSelector	getMessageSelector(String expression)
static String	getNameServerStr(String nameServer)
static <T extends RocketMQCommonProperties> T	mergeRocketMQProperties(RocketMQBinderConfigurationProperties binderConfigurationProperties, T mqProperties)

Methods inherited from class java.lang.Object

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

Method Details

mergeRocketMQProperties

public static <T extends RocketMQCommonProperties>
T mergeRocketMQProperties(RocketMQBinderConfigurationProperties binderConfigurationProperties,
 T mqProperties)

getInstanceName

public static String getInstanceName(org.apache.rocketmq.remoting.RPCHook rpcHook,
 String identify)

getNameServerStr

public static String getNameServerStr(String nameServer)

getMessageSelector

public static org.apache.rocketmq.client.consumer.MessageSelector getMessageSelector(String expression)

anonymousGroup

public static String anonymousGroup(String destination)

generate anonymous group.

Parameters:

destination - not null

Returns:

anonymous group name.