| 程序包 | 说明 |
|---|---|
| cn.springlet.rocketmq.consumer | |
| cn.springlet.rocketmq.enums | |
| cn.springlet.rocketmq.log | |
| cn.springlet.rocketmq.producer | |
| cn.springlet.rocketmq.util |
| 限定符和类型 | 方法和说明 |
|---|---|
default <B> B |
BaseMessageListenerHandler.getBodyObj(MsgKeyEnum msgKeyEnum,
com.aliyun.openservices.ons.api.Message message,
Class<B> clazz)
获取 消息参数对象
|
| 限定符和类型 | 方法和说明 |
|---|---|
static <E extends MsgKeyEnum> |
MsgKeyEnum.getMsgKeyEnum(String msgKey,
Class<E> enumClass)
根据 msgKey 获取枚举
|
static <E extends MsgKeyEnum> |
MsgKeyEnum.valueOf(Class<E> enumClass,
Object value)
找到匹配的那个枚举
|
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
LogUtil.consumerSuccess(com.aliyun.openservices.ons.api.Message msg,
MsgKeyEnum msgKeyEnum)
消息消费成功
|
static void |
LogUtil.receive(com.aliyun.openservices.ons.api.Message msg,
MsgKeyEnum msgKeyEnum,
Object bodyObj)
接收消息
|
| 限定符和类型 | 方法和说明 |
|---|---|
com.aliyun.openservices.ons.api.Message |
ProducerService.buildMessage(String topic,
String msgTag,
MsgKeyEnum msgKey,
Object messageBody)
构建消息 ,可自定义构建消息
|
void |
ProducerService.sendDelayMsg(MsgKeyEnum msgKey,
Object messageBody,
long delayTime)
发送消息 延时消息
|
void |
ProducerService.sendDelayMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
long delayTime)
发送消息 延时消息
|
void |
ProducerService.sendMsg(MsgKeyEnum msgKey,
Object messageBody)
发送消息
|
void |
ProducerService.sendMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody)
发送消息
|
void |
ProducerService.sendOneWayDelayMsg(MsgKeyEnum msgKey,
Object messageBody,
long delayTime)
发送单向消息 延时消息
|
void |
ProducerService.sendOneWayDelayMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
long delayTime)
发送单向消息 延时消息
|
void |
ProducerService.sendOneWayMsg(MsgKeyEnum msgKey,
Object messageBody)
发送单向消息
|
void |
ProducerService.sendOneWayMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody)
发送单向消息
|
void |
ProducerService.sendOneWayTimeMsg(MsgKeyEnum msgKey,
Object messageBody,
String datetime)
发送单向消息 定时消息
|
void |
ProducerService.sendOneWayTimeMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
String datetime)
发送单向消息 定时消息
|
void |
ProducerService.sendTimeMsg(MsgKeyEnum msgKey,
Object messageBody,
String datetime)
发送消息 定时消息
|
void |
ProducerService.sendTimeMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
String datetime)
发送消息 定时消息
|
| 限定符和类型 | 方法和说明 |
|---|---|
static com.aliyun.openservices.ons.api.Message |
MqSendUtil.buildMessage(String topic,
String msgTag,
MsgKeyEnum msgKey,
Object messageBody)
构建消息 ,可自定义构建消息
|
static void |
MqSendUtil.sendDelayMsg(MsgKeyEnum msgKey,
Object messageBody,
long delayTime)
发送消息 延时消息
|
static void |
MqSendUtil.sendDelayMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
long delayTime)
发送消息 延时消息
|
static void |
MqSendUtil.sendMsg(MsgKeyEnum msgKey,
Object messageBody)
发送消息
|
static void |
MqSendUtil.sendMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody)
发送消息
|
static void |
MqSendUtil.sendOneWayDelayMsg(MsgKeyEnum msgKey,
Object messageBody,
long delayTime)
发送单向消息 延时消息
|
static void |
MqSendUtil.sendOneWayDelayMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
long delayTime)
发送单向消息 延时消息
|
static void |
MqSendUtil.sendOneWayMsg(MsgKeyEnum msgKey,
Object messageBody)
发送单向消息
|
static void |
MqSendUtil.sendOneWayMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody)
发送单向消息
|
static void |
MqSendUtil.sendOneWayTimeMsg(MsgKeyEnum msgKey,
Object messageBody,
String datetime)
发送单向消息 定时消息
|
static void |
MqSendUtil.sendOneWayTimeMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
String datetime)
发送单向消息 定时消息
|
static void |
MqSendUtil.sendTimeMsg(MsgKeyEnum msgKey,
Object messageBody,
String datetime)
发送消息 定时消息
|
static void |
MqSendUtil.sendTimeMsg(MsgKeyEnum msgKey,
String msgTag,
Object messageBody,
String datetime)
发送消息 定时消息
|
Copyright © 2022. All rights reserved.