From 4b9b894bc3a3571693bcb47182ebb20ded6f4e74 Mon Sep 17 00:00:00 2001
From: wuhao <mikewuhao@163.com>
Date: Tue, 25 Jul 2017 22:33:33 +0800
Subject: [PATCH] refresh relayFilter after relay changed

---
 .../java/com/linkedin/databus/client/RelayPullThread.java  | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java b/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java
index 416241dd..a2ff24e2 100644
--- a/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java
+++ b/databus-client/databus-client-http/src/main/java/com/linkedin/databus/client/RelayPullThread.java
@@ -402,6 +402,7 @@ protected void doPickRelay(ConnectionState curState)
       {
         relayConn = _sourcesConn.getRelayConnFactory().createRelayConnection(
             serverInfo, this, _remoteExceptionHandler);
+        afterRelayChange();
         _log.info("picked a relay:" + serverInfo.toSimpleString());
       }
       catch (Exception e)
@@ -513,6 +514,11 @@ private String buildSubsList(List<DatabusSubscription> subs, Map<String, IdNameP
     sb.append("]");
     return sb.toString();
   }
+  
+  private void afterRelayChange()
+  {
+    _relayFilter = null;
+  }
 
   protected void doSourcesResponseSuccess(ConnectionState curState)
   {
@@ -1186,6 +1192,7 @@ private boolean onRelayFellOff(ConnectionState curState, Checkpoint cp, Throwabl
   @Override
   protected void tearConnection()
   {
+    afterRelayChange();
     _currentState.setRelayFellOff(false);
     super.tearConnection();
   }