We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 434acfe commit dbfc07eCopy full SHA for dbfc07e
1 file changed
google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/it/ITPubSubTest.java
@@ -116,9 +116,9 @@ public void testPublishSubscribe() throws Exception {
116
public void receiveMessage(
117
final PubsubMessage message, final AckReplyConsumer consumer) {
118
if (received.set(message)) {
119
- consumer.accept(AckReply.ACK, null);
+ consumer.accept(AckReply.ACK);
120
} else {
121
- consumer.accept(AckReply.NACK, null);
+ consumer.accept(AckReply.NACK);
122
}
123
124
})
0 commit comments