Skip to content

Commit f7c0c10

Browse files
committed
Fix test
1 parent e952943 commit f7c0c10

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

src/test/java/com/rabbitmq/stream/impl/ClientTest.java

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1076,11 +1076,14 @@ public int fragmentLength(Object obj) {
10761076
Client consumer =
10771077
cf.get(
10781078
new ClientParameters()
1079-
.chunkListener(
1080-
(client, subscriptionId, offset, messageCount1, dataSize) ->
1081-
client.credit(subscriptionId, 1))
1079+
.chunkListener(TestUtils.credit())
10821080
.messageListener(
1083-
(subscriptionId, offset, chunkTimestamp, committedChunkId, message) -> {
1081+
(subscriptionId,
1082+
offset,
1083+
chunkTimestamp,
1084+
committedChunkId,
1085+
chunkContext,
1086+
message) -> {
10841087
consumedMessageCount.incrementAndGet();
10851088
String filterValue = message.getProperties().getGroupId();
10861089
if (newFilterValue.equals(filterValue)) {

0 commit comments

Comments
 (0)