[incubator-pulsar] branch branch-1.22 updated: Fixed Lookup redirect logic on Proxy side

[ja...@apache.org]

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

jai1 pushed a commit to branch branch-1.22
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/branch-1.22 by this push:
     new 335bc33  Fixed Lookup redirect logic on Proxy side
335bc33 is described below

commit 335bc33a593378da21a5d7627688910a59d09f2c
Author: Jai Asher <ja...@ccs.neu.edu>
AuthorDate: Wed May 2 01:27:33 2018 -0700

    Fixed Lookup redirect logic on Proxy side
---
 .../main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java
index 7d4d683..148a7a4 100644
--- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java
+++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java
@@ -125,7 +125,7 @@ public class LookupProxyHandler {
                     requestId).thenAccept(result -> {
                         if (result.redirect) {
                             // Need to try the lookup again on a different broker
-                            performLookup(clientRequestId, topic, result.brokerUrl, authoritative, numberOfRetries - 1);
+                            performLookup(clientRequestId, topic, result.brokerUrl, result.authoritative, numberOfRetries - 1);
                         } else {
                             // We have the result immediately
                             String brokerUrl = connectWithTLS ? result.brokerUrlTls : result.brokerUrl;

-- 
To stop receiving notification emails like this one, please contact
jai1@apache.org.