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

[ISSUE #3627]org.apache.rocketmq.broker.processor.SendMessageProcessorTest#testProcessRequest_WithMsgBack failed (#3629)

Browse Source
This commit is contained in:
panzhi
2021-12-11 16:31:57 +08:00
committed by GitHub
parent 3a5cdfa59a
commit fcb2486f1b
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/test/java/org/apache/rocketmq/broker/processor/SendMessageProcessorTest.java
+3 -1
View File
@@ -88,7 +88,9 @@ public class SendMessageProcessorTest {
Channel mockChannel = mock(Channel.class);
when(mockChannel.remoteAddress()).thenReturn(new InetSocketAddress(1024));
when(handlerContext.channel()).thenReturn(mockChannel);
when(messageStore.lookMessageByOffset(anyLong())).thenReturn(new MessageExt());
MessageExt messageExt = new MessageExt();
messageExt.setTopic(topic);
when(messageStore.lookMessageByOffset(anyLong())).thenReturn(messageExt);
sendMessageProcessor = new SendMessageProcessor(brokerController);
}