Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

consumer exit due to AMQPHeartbeatTimeout. #2

Open
perillaroc opened this issue Aug 14, 2019 · 0 comments
Open

consumer exit due to AMQPHeartbeatTimeout. #2

perillaroc opened this issue Aug 14, 2019 · 0 comments

Comments

@perillaroc
Copy link
Member

[2019-08-13 07:41:56] INFO starting receiving message...,
[2019-08-13 22:33:35] ERROR Unexpected connection close detected: AMQPHeartbeatTimeout: ('No activity or too many missed heartbeats in the last 60 seconds',),
[2019-08-13 22:33:35] INFO Warm shutdown...,
Traceback (most recent call last):,
  File "/srv/ploto/ploto/scheduler/rabbitmq/consumer/consumer.py", line 81, in cli,
    channel.start_consuming(),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 1866, in start_consuming,
    self._process_data_events(time_limit=None),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 2027, in _process_data_events,
    self.connection.process_data_events(time_limit=time_limit),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 825, in process_data_events,
    self._flush_output(common_terminator),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 522, in _flush_output,
    raise self._closed_result.value.error,
pika.exceptions.AMQPHeartbeatTimeout: No activity or too many missed heartbeats in the last 60 seconds,
,
During handling of the above exception, another exception occurred:,
,
Traceback (most recent call last):,
  File "/srv/ploto/ploto/scheduler/rabbitmq/consumer/consumer.py", line 93, in <module>,�,
),
  File "/usr/local/lib/python3.6/site-packages/click/core.py", line 764, in __call__,
    return self.main(*args, **kwargs),
  File "/usr/local/lib/python3.6/site-packages/click/core.py", line 717, in main,
    rv = self.invoke(ctx),
  File "/usr/local/lib/python3.6/site-packages/click/core.py", line 956, in invoke,
    return ctx.invoke(self.callback, **ctx.params),
  File "/usr/local/lib/python3.6/site-packages/click/core.py", line 555, in invoke,
    return callback(*args, **kwargs),
  File "/srv/ploto/ploto/scheduler/rabbitmq/consumer/consumer.py", line 87, in cli,
    channel.stop_consuming(),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 1879, in stop_consuming,
    self._cancel_all_consumers(),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 1480, in _cancel_all_consumers,
    self.basic_cancel(consumer_tag),
  File "/usr/local/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 1758, in basic_cancel,
    consumer_tag in self._impl._consumers), consumer_tag,
AssertionError: ctag1.00b9bab26c944271a2489045701cbc3b,
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant