You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by ao...@apache.org on 2018/06/07 13:05:26 UTC

[ambari] 02/02: AMBARI-24049. Ambari-agent should report when message is received (aonishuk)

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

aonishuk pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/ambari.git

commit d743faf5f1233dac1cf596058f4e054bb4444d47
Author: Andrew Onishuk <ao...@hortonworks.com>
AuthorDate: Thu Jun 7 11:53:54 2018 +0300

    AMBARI-24049. Ambari-agent should report when message is received (aonishuk)
---
 ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py b/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py
index 49e0ce5..3403bb2 100644
--- a/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py
+++ b/ambari-agent/src/main/python/ambari_agent/HeartbeatThread.py
@@ -125,7 +125,6 @@ class HeartbeatThread(threading.Thread):
     logger.info("Sending registration request")
     logger.debug("Registration request is {0}".format(registration_request))
 
-    self.server_responses_listener.connection = self.connection
     response = self.blocking_request(registration_request, Constants.REGISTRATION_ENDPOINT)
 
     logger.info("Registration response received")
@@ -134,7 +133,6 @@ class HeartbeatThread(threading.Thread):
     self.handle_registration_response(response)
 
     for endpoint, cache, listener, subscribe_to in self.post_registration_requests:
-      listener.connection = self.connection
       # should not hang forever on these requests
       response = self.blocking_request({'hash': cache.hash}, endpoint, log_handler=listener.get_log_message)
       try:

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