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

Add comment with link to Bunny implementation for heartbeat connection check interval

parent 30ab143c1921
No related branches found
No related tags found
No related merge requests found
......@@ -57,7 +57,8 @@
# to two times the heartbeat timeout value.
# https://github.com/pika/pika/pull/1072#issuecomment-397850795
# https://github.com/rabbitmq/rabbitmq-java-client/blob/b55bd20a1a236fc2d1ea9369b579770fa0237615/src/main/java/com/rabbitmq/client/impl/AMQConnection.java#L773-L780
self._check_interval = float(timeout) * 2;
# https://github.com/ruby-amqp/bunny/blob/3259f3af2e659a49c38c2470aa565c8fb825213c/lib/bunny/session.rb#L1187-L1192
self._check_interval = float(timeout) * 2
LOGGER.debug('timeout: %f send_interval: %f check_interval: %f',
self._timeout,
......@@ -152,7 +153,7 @@
# in memory before the next statement terminates the connection.
self._connection.close(HeartbeatChecker._CONNECTION_FORCED, text)
self._connection._on_terminate(HeartbeatChecker._CONNECTION_FORCED,
self._connection._on_terminate(HeartbeatChecker._CONNECTION_FORCED, # pylint: disable=W0212
text)
@property
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment