public class RocketMqConfig extends Object
RocketMqConfig for Consumer/Producer.
Constructor and Description |
---|
RocketMqConfig() |
Modifier and Type | Method and Description |
---|---|
static void |
buildCommonConfigs(Properties props,
org.apache.rocketmq.client.ClientConfig client)
Build Common Configs.
|
static void |
buildConsumerConfigs(Properties props,
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer consumer)
Build Consumer Configs.
|
static void |
buildProducerConfigs(Properties props,
org.apache.rocketmq.client.producer.DefaultMQProducer producer)
Build Producer Configs.
|
public static final String NAME_SERVER_ADDR
public static final String NAME_SERVER_POLL_INTERVAL
public static final int DEFAULT_NAME_SERVER_POLL_INTERVAL
public static final String BROKER_HEART_BEAT_INTERVAL
public static final int DEFAULT_BROKER_HEART_BEAT_INTERVAL
public static final String PRODUCER_GROUP
public static final String PRODUCER_RETRY_TIMES
public static final int DEFAULT_PRODUCER_RETRY_TIMES
public static final String PRODUCER_TIMEOUT
public static final int DEFAULT_PRODUCER_TIMEOUT
public static final String CONSUMER_GROUP
public static final String CONSUMER_TOPIC
public static final String CONSUMER_TAG
public static final String DEFAULT_CONSUMER_TAG
public static final String CONSUMER_OFFSET_RESET_TO
public static final String CONSUMER_OFFSET_LATEST
public static final String CONSUMER_OFFSET_EARLIEST
public static final String CONSUMER_OFFSET_TIMESTAMP
public static final String CONSUMER_OFFSET_FROM_TIMESTAMP
public static final String CONSUMER_MESSAGES_ORDERLY
public static final String CONSUMER_OFFSET_PERSIST_INTERVAL
public static final int DEFAULT_CONSUMER_OFFSET_PERSIST_INTERVAL
public static final String CONSUMER_MIN_THREADS
public static final int DEFAULT_CONSUMER_MIN_THREADS
public static final String CONSUMER_MAX_THREADS
public static final int DEFAULT_CONSUMER_MAX_THREADS
public static final String CONSUMER_CALLBACK_EXECUTOR_THREADS
public static final int DEFAULT_CONSUMER_CALLBACK_EXECUTOR_THREADS
public static final String CONSUMER_BATCH_SIZE
public static final int DEFAULT_CONSUMER_BATCH_SIZE
public static final String CONSUMER_BATCH_PROCESS_TIMEOUT
public static void buildProducerConfigs(Properties props, org.apache.rocketmq.client.producer.DefaultMQProducer producer)
Build Producer Configs.
props
- Propertiesproducer
- DefaultMQProducerpublic static void buildConsumerConfigs(Properties props, org.apache.rocketmq.client.consumer.DefaultMQPushConsumer consumer)
Build Consumer Configs.
props
- Propertiesconsumer
- DefaultMQPushConsumerpublic static void buildCommonConfigs(Properties props, org.apache.rocketmq.client.ClientConfig client)
Build Common Configs.
props
- Propertiesclient
- ClientConfigCopyright © 2022 The Apache Software Foundation. All rights reserved.