Get exchange used for sending events. Arguments: conn (kombu.Connection): Connection used for sending/receiving events. name (str): Name of the exchange. Default is ``celeryev``. Note: The event type changes if Redis is used as the transport (from topic -> f
(conn, name=EVENT_EXCHANGE_NAME)
| 44 | |
| 45 | |
| 46 | def get_exchange(conn, name=EVENT_EXCHANGE_NAME): |
| 47 | """Get exchange used for sending events. |
| 48 | |
| 49 | Arguments: |
| 50 | conn (kombu.Connection): Connection used for sending/receiving events. |
| 51 | name (str): Name of the exchange. Default is ``celeryev``. |
| 52 | |
| 53 | Note: |
| 54 | The event type changes if Redis is used as the transport |
| 55 | (from topic -> fanout). |
| 56 | """ |
| 57 | ex = copy(event_exchange) |
| 58 | if conn.transport.driver_type in {'redis', 'gcpubsub'}: |
| 59 | # quick hack for Issue #436 |
| 60 | ex.type = 'fanout' |
| 61 | if name != ex.name: |
| 62 | ex.name = name |
| 63 | return ex |