From 43c812bd113c8b6176a82ba1fff03dfe2a380eb0 Mon Sep 17 00:00:00 2001 From: gaohaoxiang Date: Wed, 9 Sep 2020 10:45:16 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=B5=8B=E8=AF=95=E7=94=A8?= =?UTF-8?q?=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../consumer/FilterMessageSupportTest.java | 2 +- .../consumer/filter/FlagFilterTest.java | 20 +++++++++---------- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/FilterMessageSupportTest.java b/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/FilterMessageSupportTest.java index 7fb325eda..8cfed0895 100644 --- a/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/FilterMessageSupportTest.java +++ b/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/FilterMessageSupportTest.java @@ -68,6 +68,6 @@ public void callback(List list) throws JoyQueueException { } }); - Assert.assertEquals(1, filter.size()); + Assert.assertEquals(3, filter.size()); } } \ No newline at end of file diff --git a/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/filter/FlagFilterTest.java b/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/filter/FlagFilterTest.java index 57c19386c..ede986860 100644 --- a/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/filter/FlagFilterTest.java +++ b/joyqueue-server/joyqueue-broker-core/src/test/java/org/joyqueue/broker/consumer/filter/FlagFilterTest.java @@ -75,9 +75,9 @@ public void filter2() throws JoyQueueException { List filter = flagFilter.filter(byteBufferList, new FilterCallback() { @Override public void callback(List list) throws JoyQueueException { - Assert.assertEquals(9, list.size()); - for (int i = 0; i < 9; i++) { - Assert.assertEquals(i, Serializer.readFlag(list.get(i))); + Assert.assertEquals(8, list.size()); + for (int i = 0; i < 8; i++) { + Assert.assertEquals(i + 1, Serializer.readFlag(list.get(i))); } inCallback[0] = true; } @@ -106,9 +106,9 @@ public void filter3() throws JoyQueueException { @Override public void callback(List list) throws JoyQueueException { inCallback[0]++; - Assert.assertEquals(5, list.size()); - for (int i = 0; i < 5; i++) { - Assert.assertEquals(i, Serializer.readFlag(list.get(i))); + Assert.assertEquals(4, list.size()); + for (int i = 0; i < 4; i++) { + Assert.assertEquals(i + 1, Serializer.readFlag(list.get(i))); } } }); @@ -117,13 +117,13 @@ public void callback(List list) throws JoyQueueException { Assert.assertEquals(5, Serializer.readFlag(filter1.get(0))); Assert.assertEquals(1, inCallback[0]); - List filter2 = flagFilter.filter(byteBufferList.subList(6, 10), new FilterCallback() { + List filter2 = flagFilter.filter(byteBufferList.subList(6, 9), new FilterCallback() { @Override public void callback(List list) throws JoyQueueException { inCallback[0]++; - Assert.assertEquals(3, list.size()); - for (int i = 0; i < 3; i++) { - Assert.assertEquals(i + 6, Serializer.readFlag(list.get(i))); + Assert.assertEquals(2, list.size()); + for (int i = 0; i < 2; i++) { + Assert.assertEquals(i + 7, Serializer.readFlag(list.get(i))); } } });