opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE# 6650]: Fix using the deprecated method MessgaeStore#checkInDiskByConsumeOffset (#6651)

Browse Source 
* fix(tieredstorage): fix using deprecated method `MessageStore#checkInDiskByConsumeOffset`

1. fix using deprecated method `MessageStore#checkInDiskByConsumeOffset`

* test(tieredstorage): replace `checkInDiskeByConsumeOffset` with `checkInStoreByConsumeOffset`

1. replace `checkInDiskeByConsumeOffset` with `checkInStoreByConsumeOffset`
This commit is contained in:
TheR1sing3un
2023-04-27 17:16:39 +08:00
committed by GitHub
parent b00c82cacc
commit dcf7ccdd9b
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java
+1 -1
View File
@@ -153,7 +153,7 @@ public class TieredMessageStore extends AbstractPluginMessageStore {
if (result.getStatus() == GetMessageStatus.OFFSET_FOUND_NULL ||
result.getStatus() == GetMessageStatus.OFFSET_OVERFLOW_ONE ||
result.getStatus() == GetMessageStatus.OFFSET_OVERFLOW_BADLY) {
if (next.checkInDiskByConsumeOffset(topic, queueId, offset)) {
if (next.checkInStoreByConsumeOffset(topic, queueId, offset)) {
logger.debug("TieredMessageStore#getMessageAsync: not found message, try to get message from next store: topic: {}, queue: {}, queue offset: {}, tiered store result: {}, min offset: {}, max offset: {}",
topic, queueId, offset, result.getStatus(), result.getMinOffset(), result.getMaxOffset());
TieredStoreMetricsManager.fallbackTotal.add(1, latencyAttributes);
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/TieredMessageStoreTest.java
+1 -1
View File
@@ -189,7 +189,7 @@ public class TieredMessageStoreTest {
Properties properties = new Properties();
properties.setProperty("tieredStorageLevel", "3");
configuration.update(properties);
when(nextStore.checkInDiskByConsumeOffset(anyString(), anyInt(), anyLong())).thenReturn(true);
when(nextStore.checkInStoreByConsumeOffset(anyString(), anyInt(), anyLong())).thenReturn(true);
Assert.assertSame(result2, store.getMessage("group", mq.getTopic(), mq.getQueueId(), 0, 0, null));
}