Stephan Kulow
a73054b189
Fix rabbitmq acknowledge: first ACK then check the content
2019-05-20 11:43:25 +02:00
Stephan Kulow
6297dacf8b
Acknowledge the rabbitmq message
...
We need to ACK the rabbitmq message for the server to erase it in the
queue - otherwise they are piling up endlessly. As we quit the services
every hour the queue is reset at that point, but that still makes monitoring
the server quite hard as the queues tend to be full all the time
2019-05-18 20:57:05 +02:00
Stephan Kulow
e0a2d7e653
Close the rabbit connection more carefully
...
Fixes #1985
2019-05-13 11:37:06 +02:00
Stephan Kulow
fefa1adaf7
PubSubConsumer: Fix cancel callbacks
2019-05-02 11:55:08 +02:00
Stephan Kulow
22ff335e45
PubSubConsumer: fix timer API and close callbacks
2019-05-02 11:26:32 +02:00
Stephan Kulow
79109efe55
PubSubConsumer: add SSL options and fix reason API
2019-05-02 11:14:06 +02:00
0877289bf3
PubSubConsumer: adopt to Pika 1.0 change
2019-05-02 17:05:53 +08:00
Stephan Kulow
fa6e49559b
PubsubConsumer: Implement max runtime
...
To have a clean break and a limited log file for monitoring bots
2019-03-20 06:47:37 +01:00
Stephan Kulow
0e6951e653
Output something every 5 minutes to show activity on the console
...
To make sure we know if the service hangs or is still kicking
2019-02-21 16:08:32 +01:00
Stephan Kulow
4ceb0a2fa3
Support connecting suse in PubSubConsumer
2019-01-26 17:57:51 +01:00
Stephan Kulow
798dbcd66e
Only use amqp_prefix as config
...
This way we can easily have common config between the instance (in this
case socket_timeout, which is default 0.25 and way too low for
provo->NBG)
2019-01-26 17:57:15 +01:00
Stephan Kulow
b350abaf5a
Reduce debug level for channel close
2019-01-26 17:56:29 +01:00
Stephan Kulow
d5947f5c19
Refactored rabbit-openqa to be based on PubSubConsumer
...
The base class listens to openSUSE pubsub messages (and can be used
standalone) and rabbit-openqa just overwrites the keys and the on_message
handler
2018-10-12 11:06:54 +02:00
