Skip to content

Commit 4b187c6

Browse files
authored
[ISSUE #9945] Use UniqueKey as the TimerDelKey value when no namespace is appended (#9951)
1 parent 541fdad commit 4b187c6

File tree

1 file changed

+1
-1
lines changed
  • store/src/main/java/org/apache/rocketmq/store/timer/rocksdb

1 file changed

+1
-1
lines changed

store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/Timeline.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ private String extractUniqKey(String deleteKey) throws IllegalArgumentException
288288
}
289289
int separatorIndex = deleteKey.indexOf(DELETE_KEY_SPLIT);
290290
if (separatorIndex == -1) {
291-
throw new IllegalArgumentException("Invalid deleteKey format");
291+
return deleteKey;
292292
}
293293
return deleteKey.substring(separatorIndex + 1);
294294
}

0 commit comments

Comments
 (0)