public final class RocketMqUtils extends Object
Constructor and Description |
---|
RocketMqUtils() |
Modifier and Type | Method and Description |
---|---|
static Scheme |
createScheme(Properties props)
Create Scheme by Properties.
|
static List<Object> |
generateTuples(org.apache.rocketmq.common.message.Message msg,
Scheme scheme)
Generate Storm tuple values by Message and Scheme.
|
static boolean |
getBoolean(Properties props,
String key,
boolean defaultValue) |
static int |
getInteger(Properties props,
String key,
int defaultValue) |
static long |
getLong(Properties props,
String key,
long defaultValue) |
public static int getInteger(Properties props, String key, int defaultValue)
public static long getLong(Properties props, String key, long defaultValue)
public static boolean getBoolean(Properties props, String key, boolean defaultValue)
public static Scheme createScheme(Properties props)
Create Scheme by Properties.
props
- PropertiesCopyright © 2022 The Apache Software Foundation. All rights reserved.