Skip to content

Commit 6ed72ea

Browse files
committed
fixed test
1 parent 912c755 commit 6ed72ea

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumersTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -128,15 +128,15 @@ public void testSendMessage() throws BrokerServiceException {
128128
assertEquals(byteBuf.toString(UTF_8), "message" + index);
129129
};
130130
return mockPromise;
131-
}).when(consumerMock).sendMessages(any(List.class), any(EntryBatchSizes.class), any(),
132-
anyInt(), anyLong(), anyLong(), any(RedeliveryTracker.class));
131+
}).when(consumerMock).sendMessages(any(List.class), any(List.class), any(EntryBatchSizes.class), any(),
132+
anyInt(), anyLong(), anyLong(), any(RedeliveryTracker.class), anyLong());
133133
try {
134134
nonpersistentDispatcher.sendMessages(entries);
135135
} catch (Exception e) {
136136
fail("Failed to sendMessages.", e);
137137
}
138-
verify(consumerMock, times(1)).sendMessages(any(List.class), any(EntryBatchSizes.class),
139-
eq(null), anyInt(), anyLong(), anyLong(), any(RedeliveryTracker.class));
138+
verify(consumerMock, times(1)).sendMessages(any(List.class), any(List.class), any(EntryBatchSizes.class),
139+
eq(null), anyInt(), anyLong(), anyLong(), any(RedeliveryTracker.class), anyLong());
140140
}
141141

142142
@Test(timeOut = 10000)

0 commit comments

Comments
 (0)