10 Commits

Author SHA1 Message Date
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