[pulsar] branch master updated: fix cause deadlock while use subscribeAsync demo in java client doc. (#4649)

[mmerli]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new bbaf2d9  fix cause deadlock while use subscribeAsync demo in java 
client doc. (#4649)
bbaf2d9 is described below

commit bbaf2d9eadbf678fd22e1541cc583b2607499714
Author: lipenghui <peng...@apache.org>
AuthorDate: Tue Jul 2 06:20:09 2019 +0800

    fix cause deadlock while use subscribeAsync demo in java client doc. (#4649)
---
 site2/docs/client-libraries-java.md | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/site2/docs/client-libraries-java.md 
b/site2/docs/client-libraries-java.md
index 35887fc..16750c6 100644
--- a/site2/docs/client-libraries-java.md
+++ b/site2/docs/client-libraries-java.md
@@ -306,16 +306,14 @@ Pattern allTopicsInNamespace = 
Pattern.compile("persistent://public/default.*");
 consumerBuilder
         .topics(topics)
         .subscribeAsync()
-        .thenAccept(consumer -> {
-            do {
-                try {
-                    Message msg = consumer.receive();
-                    // Do something with the received message
-                } catch (PulsarClientException e) {
-                    e.printStackTrace();
-                }
-            } while (true);
-        });
+        .thenAccept(this::receiveMessageFromConsumer);
+
+private void receiveMessageFromConsumer(Consumer consumer) {
+    consumer.receiveAsync().thenAccept(message -> {
+                // Do something with the received message
+                receiveMessageFromConsumer(consumer);
+            });
+}
 ```
 
 ### Subscription modes