This is an automated email from the ASF dual-hosted git repository.
dcapwell pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
The following commit(s) were added to refs/heads/trunk by this push:
new 29b53d20 Fix ReadDataTest test failures (#287)
29b53d20 is described below
commit 29b53d2006bf856f7834dfa70d02a1408eadc9a8
Author: Alan Wang <[email protected]>
AuthorDate: Fri Aug 14 16:09:54 2026 -0700
Fix ReadDataTest test failures (#287)
patch by Alan Wang; reviewed by David Capwell, Jyothsna Konisa for
CASSANDRA-21573
---
accord-core/src/test/java/accord/messages/ReadDataTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/accord-core/src/test/java/accord/messages/ReadDataTest.java
b/accord-core/src/test/java/accord/messages/ReadDataTest.java
index a508c0e4..3bc2b16d 100644
--- a/accord-core/src/test/java/accord/messages/ReadDataTest.java
+++ b/accord-core/src/test/java/accord/messages/ReadDataTest.java
@@ -144,7 +144,7 @@ class ReadDataTest
state.apply();
state.readResult.setSuccess(Mockito.mock(Data.class));
- Mockito.verify(state.sink).reply(Mockito.eq(state.node.id()),
Mockito.eq(replyContext), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.eq(null));
+ Mockito.verify(replyContext).reply(Mockito.eq(state.node.id()),
Mockito.eq(state.sink), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.isNull());
});
}
@@ -168,7 +168,7 @@ class ReadDataTest
state.apply();
state.readResult.setSuccess(Mockito.mock(Data.class));
- Mockito.verify(state.sink).reply(Mockito.eq(state.node.id()),
Mockito.eq(replyContext), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.eq(null));
+ Mockito.verify(replyContext).reply(Mockito.eq(state.node.id()),
Mockito.eq(state.sink), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.isNull());
});
}
@@ -199,7 +199,7 @@ class ReadDataTest
ReplyContext replyContext = state.process();
- Mockito.verify(state.sink).reply(Mockito.eq(state.node.id()),
Mockito.eq(replyContext), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.eq(null));
+ Mockito.verify(replyContext).reply(Mockito.eq(state.node.id()),
Mockito.eq(state.sink), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.isNull());
});
}
@@ -215,7 +215,7 @@ class ReadDataTest
})));
ReplyContext replyContext = state.process();
- Mockito.verify(state.sink).reply(Mockito.eq(state.node.id()),
Mockito.eq(replyContext), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.eq(null));
+ Mockito.verify(replyContext).reply(Mockito.eq(state.node.id()),
Mockito.eq(state.sink), Mockito.eq(ReadData.CommitOrReadNack.Redundant),
Mockito.isNull());
});
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
