get_exchange

Get exchange used for sending events.

def get_exchange(
    conn: kombu.Connection,
    name: string = EVENT_EXCHANGE_NAME
) - > kombu.Exchange

Get exchange used for sending events.

Parameters

Name	Type	Description
conn	kombu.Connection	Connection used for sending/receiving events; used to determine if the transport requires a fanout exchange type.
name	string = EVENT_EXCHANGE_NAME	The name of the exchange to be returned.

Returns

Type	Description
kombu.Exchange	A copy of the event exchange configured with the appropriate name and transport type (topic or fanout).