Skip to content
Snippets Groups Projects
Commit b2f9dea1a755 authored by Luke Bakken's avatar Luke Bakken
Browse files

PR review

parent a7f1960d3018
Branches
No related tags found
No related merge requests found
...@@ -7,8 +7,10 @@ ...@@ -7,8 +7,10 @@
class HeartbeatChecker(object): class HeartbeatChecker(object):
"""Sends heartbeats to the broker and checks to make sure that the broker's """Sends heartbeats to the broker twice during the provided interval
heartbeat is received before the expected timeout expires. and checks at a different interval to make sure that the broker's
heartbeat is received as expected. See the parameter list for more
details.
""" """
_CONNECTION_FORCED = 320 _CONNECTION_FORCED = 320
...@@ -17,8 +19,8 @@ ...@@ -17,8 +19,8 @@
def __init__(self, connection, interval): def __init__(self, connection, interval):
"""Create a heartbeat on the connection that sends two heartbeat frames """Create a heartbeat on the connection that sends two heartbeat frames
within the specified timeout window. Also checks to ensure heartbeats within the specified interval. Also checks to ensure heartbeats are
are received from the broker. received from the broker at a different interval explained below.
:param pika.connection.Connection: Connection object :param pika.connection.Connection: Connection object
:param int interval: Heartbeat check interval. Note: heartbeats will :param int interval: Heartbeat check interval. Note: heartbeats will
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment