U .e;@sRdZddlmZddlZddlZddlZddlmZddlm Z m Z dZ dZ dZ d Zd Zed d Ze ejed e ZeeedeedeededpddZZ[[dZdedddd<erXddlmZmZddlmZm Z ddl!m"Z"m#Z#m$Z$ddl%m&Z&ddl'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.ddl-m/Z/ddl0m1Z1ddl2m3Z3d d!gd"d#d$gd%gd&d'gd(d)gd*gd+d,gd-d.gd/Z4iZ5e46D]\Z7Z6e6D]Z8e7e5e8<qqGd0d1d1e3Z9ej:e;Z?e@eAeeBe5e e e eeeCeeed2 ejDEd3rNejDj?d4d4d5dd6lFmGZGeGHdS)7zMessaging library for Python.) annotationsN) namedtuple)Anycastz5.3.2z Ask Solemzauvipy@gmail.comzhttps://kombu.readthedocs.iozrestructuredtext enversion_info_t)majorminormicro releaselevelserialz(\d+)\.(\d+).(\d+)(.+)?TFZ kcah_acitats) eventloopuuid)BrokerConnection Connection)ExchangeQueuebinding)Message)ConsumerProducer) connections producers)disable_insecure_serializers)enable_insecure_serializers) parse_url) ModuleTyperrrrrrrrrrrrrrr)zkombu.connectionz kombu.entityz kombu.messagezkombu.messagingz kombu.poolszkombu.utils.urlz kombu.commonzkombu.serializationc@s.eZdZdZdddddZddd d Zd S) modulezCustomized Python module.strr)namereturncCsT|tkrHtt|dd|g}t|jD]}t||t||q&t||St||S)N)object_origins __import__ all_by_module__name__setattrgetattrr __getattribute__)selfr#r!Z extra_namer-2/tmp/pip-unpacked-wheel-48hrr5dg/kombu/__init__.py __getattr__Ks  zmodule.__getattr__z list[str])r$cCsttj}|d|S)N)__file____path____doc____all__ __docformat__r(r1VERSION __package__ __version__ __author__ __contact__ __homepage__r4)list new_moduler3extend)r,resultr-r-r.__dir__Ss  zmodule.__dir__N)r( __module__ __qualname__r2r/r?r-r-r-r.r!Hsr!) r0r1r2r3r7r8r9r:r4r6r version_infor5ZKOMBU_LOG_DEBUG1)ZKOMBU_LOG_CHANNELZKOMBU_LOG_CONNECTION)debug)Ir2 __future__rosresys collectionsrtypingrrr7r8r9r:r4rMatchmatchgroups_tempintr5rBZ STATICA_HACKglobalsupperZ kombu.commonrrZkombu.connectionrrZ kombu.entityrrrZ kombu.messagerZkombu.messagingrrZ kombu.poolsrrZkombu.serializationrrZkombu.utils.urlrtypesr r'r%items_moduleitemr!modulesr(Z old_moduler<__dict__updater0r1tupler6environgetutilsrD setup_loggingr-r-r-r.s