We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 41c2a60 commit 7750db7Copy full SHA for 7750db7
broker/src/test/java/org/apache/rocketmq/broker/processor/RecallMessageProcessorTest.java
@@ -106,7 +106,7 @@ public void testBuildMessage() {
106
Map<String, String> properties = MessageDecoder.string2messageProperties(msg.getPropertiesString());
107
Assert.assertEquals(timestampStr, properties.get(MessageConst.PROPERTY_TIMER_DELIVER_MS));
108
Assert.assertEquals(id, properties.get(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX));
109
- Assert.assertEquals(id, properties.get(MessageConst.PROPERTY_TIMER_DEL_UNIQKEY));
+ Assert.assertEquals(TOPIC + "+" + id, properties.get(MessageConst.PROPERTY_TIMER_DEL_UNIQKEY));
110
}
111
112
@Test
0 commit comments