File: //home/arjun/projects/env/lib/python3.10/site-packages/kombu/__pycache__/__init__.cpython-310.pyc
o
'we; � @ sN d Z ddlmZ ddlZddlZddlZddlmZ ddlm Z m
Z
dZ dZ dZ
d Zd
Zed d �Ze
eje�d
e ���� Zeeed �eed �eed �ed pRdd� ZZ[[dZde� dddd� �� < er�ddlm Z m Z ddl m Z m Z ddl!m"Z"m#Z#m$Z$ ddl%m&Z& ddl'm(Z(m)Z) ddl*m+Z+m,Z, dd l-m.Z. dd l-m/Z/ dd l0m1Z1 dd l2m3Z3 d d!gg d�d"gd#d$gd%d&gd'gd(d)gd*d+gd,�Z4i Z5e4�6� D ]
\Z7Z6e6D ]Z8e7e5e8< q�q�G d-d.� d.e3�Z9ej:e; Z<e9e;� Z=ej:e;< e=j>�?e@eAe eBe5�e e e
eeeCeeed/�
� ejD�Ed0��r%ejDj?d1d1d2� dd3lFmGZG eG�H� dS dS )4z Messaging library for Python.� )� annotationsN)�
namedtuple)�Any�castz5.3.4z Ask Solemzauvipy@gmail.comz https://kombu.readthedocs.iozrestructuredtext en�version_info_t)�major�minor�micro� releaselevel�serialz(\d+)\.(\d+).(\d+)(.+)?� � � � TF� kcah_acitats���)� eventloop�uuid)�BrokerConnection�
Connection)�Exchange�Queue�binding)�Message)�Consumer�Producer)� connections� producers)� disable_insecure_serializers)�enable_insecure_serializers)� parse_url)�
ModuleTyper r r r r r r r r r r r )zkombu.connectionz kombu.entityz
kombu.messagezkombu.messagingz kombu.poolszkombu.utils.urlz kombu.commonzkombu.serializationc @ s$ e Zd ZdZd dd�Zd
d d
�Zd S )�modulezCustomized Python module.�name�str�returnr c C sT |t v r$tt | d d |g�}t|j D ] }t| |t||�� qt||�S t�| |�S )N)�object_origins�
__import__�
all_by_module�__name__�setattr�getattrr! �__getattribute__)�selfr# r" �
extra_name� r/ �G/home/arjun/projects/env/lib/python3.10/site-packages/kombu/__init__.py� __getattr__K s
zmodule.__getattr__� list[str]c C s t tj�}|�d� |S )N)�__file__�__path__�__doc__�__all__�
__docformat__r) r4 �VERSION� __package__� __version__�
__author__� __contact__� __homepage__r7 )�list�
new_moduler6 �extend)r- �resultr/ r/ r0 �__dir__S s
zmodule.__dir__N)r# r$ r% r )r% r2 )r) �
__module__� __qualname__r5 r1 rB r/ r/ r/ r0 r" H s
r" )
r3 r4 r5 r6 r: r; r< r= r7 r9 r � version_infor8 �KOMBU_LOG_DEBUG�1)�KOMBU_LOG_CHANNEL�KOMBU_LOG_CONNECTION)�debug)Ir5 �
__future__r �os�re�sys� collectionsr �typingr r r: r; r< r= r7 r �Match�match�groups�_temp�intr8 rE � STATICA_HACK�globals�upper� kombu.commonr r �kombu.connectionr r � kombu.entityr r r �
kombu.messager �kombu.messagingr r � kombu.poolsr r �kombu.serializationr r �kombu.utils.urlr �typesr! r( r& �items�_module�itemr" �modulesr) �
old_moduler? �__dict__�updater3 r4 �tupler9 �environ�get�utilsrJ �
setup_loggingr/ r/ r/ r0 �<module> s�
��*� ��
�
� �