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

[ISSUE #3949] fix test cases

Browse Source
This commit is contained in:
kaiyi.lk
2022-07-13 11:29:41 +08:00
committed by zhouxiang
parent d44949f90b
commit 989bd3ae53
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/test/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionServiceTest.java
-2
View File
@@ -126,12 +126,10 @@ public class ClusterTransactionServiceTest extends BaseServiceTest {
assertEquals(Lists.newArrayList(BROKER_ADDR, BROKER_ADDR), brokerAddrArgumentCaptor.getAllValues());
List<HeartbeatData> heartbeatDataList = heartbeatDataArgumentCaptor.getAllValues();
assertEquals(2, heartbeatDataList.get(0).getProducerDataSet().size());
for (ProducerData producerData : heartbeatDataList.get(0).getProducerDataSet()) {
groupSet.remove(producerData.getGroupName());
}
assertEquals(1, heartbeatDataList.get(1).getProducerDataSet().size());
for (ProducerData producerData : heartbeatDataList.get(1).getProducerDataSet()) {
groupSet.remove(producerData.getGroupName());
}