Provide function to initialise RabbitMQ backend for OQ signalling
Bug #809199 reported by
Muharem Hrnjadovic
This bug affects 1 person
Affects | Status | Importance | Assigned to | Milestone | |
---|---|---|---|---|---|
OpenQuake (deprecated) |
Fix Released
|
High
|
Gabriele Favalessa |
Bug Description
It is envisioned that all OQ python signalling operations will be backed by a RabbitMQ transport.
An init_signalling() function that creates a 'signalling' topic exchange (using the broker host/vhost specified in a configuration file or via environment variables) and that returns an amqp channel is to be provided.
tags: | added: error-feedback |
tags: | added: messaging |
description: | updated |
summary: |
- Initialise RabbitMQ backend for logging upon OQ job start-up + Provide function to initialise RabbitMQ backend for OQ signalling |
Changed in openquake: | |
status: | New → Confirmed |
importance: | Undecided → High |
milestone: | none → 0.4.2 |
tags: |
added: job-supervision removed: error-feedback |
Changed in openquake: | |
assignee: | nobody → Muharem Hrnjadovic (al-maisan) |
Changed in openquake: | |
milestone: | 0.4.2 → 0.4.3 |
Changed in openquake: | |
assignee: | Muharem Hrnjadovic (al-maisan) → Gabriele Favalessa (favalex) |
status: | Confirmed → In Progress |
Changed in openquake: | |
status: | Fix Committed → Fix Released |
To post a comment you must log in.
Fixed by https:/ /github. com/gem/ openquake/ pull/464
See the openquake. signalling module, in particular the connect function.