| 程序包 | 说明 |
|---|---|
| org.joyqueue.server.retry | |
| org.joyqueue.server.retry.api | |
| org.joyqueue.server.retry.util |
| 限定符和类型 | 方法和说明 |
|---|---|
List<RetryMessageModel> |
NullMessageRetry.getRetry(String topic,
String app,
short count,
long startIndex) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
NullMessageRetry.addRetry(List<RetryMessageModel> retryMessageModelList) |
| 限定符和类型 | 方法和说明 |
|---|---|
List<RetryMessageModel> |
MessageRetry.getRetry(String topic,
String app,
short count,
long startIndex)
查询指定主题和个数的重试消息
该接口要求实现类返回非空List, 即要么返回非空List,要么抛出异常
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
MessageRetry.addRetry(List<RetryMessageModel> retryMessageModelList)
增加重试
|
| 限定符和类型 | 方法和说明 |
|---|---|
static RetryMessageModel |
RetrySerializerUtil.deserialize(io.netty.buffer.ByteBuf buffer) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ByteBuffer |
RetrySerializerUtil.serialize(RetryMessageModel retryMessageModel) |
Copyright © 2020 Joyqueue Community. All rights reserved.