o
    ?Zc                     @   s*  d Z ddlZddlZddlZddlmZ dZdZdZdZ	dZ
ed	d
Zede Zeeed eed eed ed p@dd ZZ[[dZde dddd  < erddlmZmZ ddlmZmZ ddlmZmZmZ ddlm Z  ddl!m"Z"m#Z# ddl$m%Z%m&Z& ddl'm(Z( ddl'm)Z) ddl*m+Z+ ddl,m-Z- ddgg dd gd!d"gd#d$gd%gd&d'gd(d)gd*Z.i Z/e.0 D ]\Z1Z0e0D ]Z2e1e/e2< qqG d+d, d,e-Z1ej3e4 Z5e1e4 Z6ej3e4< e6j78e9e:e e;e/eeee	e
e<eeed- ej=>d.rej=j8d/d/d0 dd1l?m@Z@ e@A  dS dS )2zMessaging library for Python.    N)
namedtuplez5.2.4z	Ask Solemz'auvipy@gmail.com, ask@celeryproject.orgzhttps://kombu.readthedocs.iozrestructuredtext 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   )zkombu.connectionzkombu.entityzkombu.messagezkombu.messagingzkombu.poolszkombu.utils.urlzkombu.commonzkombu.serializationc                   @   s    e Zd ZdZdd Zdd ZdS )modulezCustomized Python module.c                 C   sT   |t v r$tt | d d |g}t|j D ]}t| |t|| qt||S t| |S )N)object_origins
__import__all_by_module__name__setattrgetattrr   __getattribute__)selfnamer   
extra_name r*   D/var/www/chikooza/env/lib/python3.10/site-packages/kombu/__init__.py__getattr__H   s   
zmodule.__getattr__c                 C   s   t tj}|d |S )N)__file____path____doc____all____docformat__r#   r.   VERSION__package____version__
__author____contact____homepage__r1   )list
new_moduler0   extend)r'   resultr*   r*   r+   __dir__P   s   

zmodule.__dir__N)r#   
__module____qualname__r/   r,   r<   r*   r*   r*   r+   r   E   s    r   )r-   r.   r/   r0   r4   r5   r6   r7   r1   r3   r   version_infor2   KOMBU_LOG_DEBUG1)KOMBU_LOG_CHANNELKOMBU_LOG_CONNECTION)debug)Br/   osresyscollectionsr   r4   r5   r6   r7   r1   r   matchgroups_tempintr2   r?   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    itemsr   itemmodulesr#   
old_moduler9   __dict__updater-   r.   tupler3   environgetutilsrD   setup_loggingr*   r*   r*   r+   <module>   s    
*

