File: //usr/local/lib/python3.9/site-packages/kombu/transport/virtual/__pycache__/exchange.cpython-39.pyc
a
X>h � @ sr d Z ddlmZ ddlZddlmZ G dd� d�ZG dd� de�ZG d d
� d
e�ZG d d � d e�Z eee d
�Z
dS )z�Virtual AMQ Exchange.
Implementations of the standard exchanges defined
by the AMQ protocol (excluding the `headers` exchange).
� )� annotationsN)� escape_regexc @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d
� ZdS ) � ExchangeTypez�Base class for exchanges.
Implements the specifics for an exchange type.
Arguments:
---------
channel (ChannelT): AMQ Channel.
Nc C s
|| _ d S �N)�channel)�selfr � r �J/usr/local/lib/python3.9/site-packages/kombu/transport/virtual/exchange.py�__init__ s zExchangeType.__init__c C s t d��dS )z�Lookup all queues matching `routing_key` in `exchange`.
Returns
-------
str: queue name, or 'default' if no queues matched.
zsubclass responsibilityN)�NotImplementedError�r �table�exchange� routing_key�defaultr r r �lookup s zExchangeType.lookupc C s
|d|fS )z�Prepare queue-binding.
Returns
-------
Tuple[str, Pattern, str]: of `(routing_key, regex, queue)`
to be stored for bindings to this exchange.
Nr �r �queuer r � argumentsr r r � prepare_bind& s zExchangeType.prepare_bindc C s8 ||d ko6||d ko6||d ko6|p*i |d p4i kS )z3Return true if `prev` and `exchange` is equivalent.�type�durable� auto_deleter r )r �prevr r r r r r r r �
equivalent0 s
�
��zExchangeType.equivalent) �__name__�
__module__� __qualname__�__doc__r r
r r r r r r r r s
r c @ s$ e Zd ZdZdZdd� Zdd� ZdS )�DirectExchangezTDirect exchange.
The `direct` exchange routes based on exact routing keys.
�directc s � fdd�|D �S )Nc s h | ]\}}}|� kr|�qS r r )�.0�rkey�_r �r r r � <setcomp>B s �z(DirectExchange.lookup.<locals>.<setcomp>r r r r$ r r A s
�zDirectExchange.lookupc K s6 | j j}| j j}|||�D ]}|||fi |�� qd S r )r �_lookup�_put�r �messager r �kwargsr& r' r r r r �deliverG s zDirectExchange.deliverN�r r r r r r r+ r r r r r 9 s r c @ sJ e Zd ZdZdZddd�Zi Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dS )�
TopicExchangez�Topic exchange.
The `topic` exchange routes messages based on words separated by
dots, using wildcard characters ``*`` (any single word), and ``#``
(one or more words).
�topicz.*?[^\.]z.*?)�*�#c s � �fdd�|D �S )Nc s" h | ]\}}}�� |� �r|�qS r )�_match)r! r" �patternr �r r r r r% ` s �z'TopicExchange.lookup.<locals>.<setcomp>r r r r3 r r _ s �zTopicExchange.lookupc sL | j j}| j j}| j j� � fdd�|||�D �D ]}|||fi |�� q0d S )Nc s g | ]}|r|� kr|�qS r r )r! �q�Z
deadletterr r �
<listcomp>i s �z)TopicExchange.deliver.<locals>.<listcomp>)r r& r' Zdeadletter_queuer( r r5 r r+ e s
zTopicExchange.deliverc C s || � |�|fS r )�key_to_patternr r r r r m s zTopicExchange.prepare_bindc s( dd� � fdd�t|d��d�D �� S )z0Get the corresponding regex for any routing key.z^%s$z\.c 3 s | ]}� j �||�V qd S r )� wildcards�get)r! �word�r r r � <genexpr>r s �z/TopicExchange.key_to_pattern.<locals>.<genexpr>z.#*�.)�joinr �split)r r" r r; r r7 p s �z TopicExchange.key_to_patternc C sD z| j | }W n* ty8 t�|tj� }| j |< Y n0 |�|�S )z�Match regular expression (cached).
Same as :func:`re.match`, except the regex is compiled and cached,
then reused on subsequent matches with the same pattern.
)� _compiled�KeyError�re�compile�U�match)r r2 �stringZcompiledr r r r1 w s
zTopicExchange._matchN) r r r r r r8 r@ r r+ r r7 r1 r r r r r- N s �r- c @ s$ e Zd ZdZdZdd� Zdd� ZdS )�FanoutExchangea� Fanout exchange.
The `fanout` exchange implements broadcast messaging by delivering
copies of all messages to all queues bound to the exchange.
To support fanout the virtual channel needs to store the table
as shared state. This requires that the `Channel.supports_fanout`
attribute is set to true, and the `Channel._queue_bind` and
`Channel.get_table` methods are implemented.
See Also
--------
the redis backend for an example implementation of these methods.
�fanoutc C s dd� |D �S )Nc S s h | ]\}}}|�qS r r )r! r# r r r r r% � � z(FanoutExchange.lookup.<locals>.<setcomp>r r r r r r � s zFanoutExchange.lookupc K s$ | j jr | j j|||fi |�� d S r )r Zsupports_fanoutZ _put_fanout)r r) r r r* r r r r+ � s ��zFanoutExchange.deliverNr, r r r r rG � s rG )r r. rH ) r �
__future__r rB Zkombu.utils.textr r r r- rG ZSTANDARD_EXCHANGE_TYPESr r r r �<module> s +6 �