Example fixes to comply with changes to the AckReplyConsumer interface.

davidtorres · davidtorres · commit 3e906e698e9b · 2017-03-20T14:54:27.000-04:00
diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateSubscriptionAndPullMessages.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateSubscriptionAndPullMessages.java
@@ -46,7 +46,7 @@ public static void main(String... args) throws Exception {
           @Override
           public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
             System.out.println("got message: " + message.getData().toStringUtf8());
-            consumer.accept(AckReply.ACK, null);
+            consumer.accept(AckReply.ACK);
           }
         };
     Subscriber subscriber = null;
diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/MessageReceiverSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/MessageReceiverSnippets.java
@@ -51,9 +51,9 @@ public MessageReceiver messageReceiver() {
     MessageReceiver receiver = new MessageReceiver() {
       public void receiveMessage(final PubsubMessage message, final AckReplyConsumer consumer) {
         if (blockingQueue.offer(message)) {
-          consumer.accept(AckReply.ACK, null);
+          consumer.accept(AckReply.ACK);
         } else {
-          consumer.accept(AckReply.NACK, null);
+          consumer.accept(AckReply.NACK);
         }
       }
     };

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public static void main(String... args) throws Exception {`
`46`	`46`	`@Override`
`47`	`47`	`public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {`
`48`	`48`	`System.out.println("got message: " + message.getData().toStringUtf8());`
`49`		`- consumer.accept(AckReply.ACK, null);`
	`49`	`+ consumer.accept(AckReply.ACK);`
`50`	`50`	`}`
`51`	`51`	`};`
`52`	`52`	`Subscriber subscriber = null;`
Original file line number	Diff line number	Diff line change
`@@ -51,9 +51,9 @@ public MessageReceiver messageReceiver() {`
`51`	`51`	`MessageReceiver receiver = new MessageReceiver() {`
`52`	`52`	`public void receiveMessage(final PubsubMessage message, final AckReplyConsumer consumer) {`
`53`	`53`	`if (blockingQueue.offer(message)) {`
`54`		`- consumer.accept(AckReply.ACK, null);`
	`54`	`+ consumer.accept(AckReply.ACK);`
`55`	`55`	`} else {`
`56`		`- consumer.accept(AckReply.NACK, null);`
	`56`	`+ consumer.accept(AckReply.NACK);`
`57`	`57`	`}`
`58`	`58`	`}`
`59`	`59`	`};`