o h~ @sdZddlmZddlmZddlmZd6ddZid d d d d d dddddddddddddddddddddd d!d d"d#d$d#d%d&d'd(d)d*d+d,d-d. ZiZ d7d8d2d3Z d7d8d4d5Z d/S)9zBuilt-in transports.) annotations)_detect_environment)symbol_by_namereturn bool | NonecCs2tdkrzddl}WdStyYdSwdS)z/Return true if :pypi:`librabbitmq` can be used.defaultrNT)r librabbitmq ImportError)rr U/var/www/Befach/backend/venv/lib/python3.10/site-packages/kombu/transport/__init__.pysupports_librabbitmq s   r amqpz kombu.transport.pyamqp:Transportamqpsz#kombu.transport.pyamqp:SSLTransportpyamqprz%kombu.transport.librabbitmq:Transportconfluentkafkaz(kombu.transport.confluentkafka:Transportkafkamemoryz kombu.transport.memory:Transportrediszkombu.transport.redis:TransportredissSQSzkombu.transport.SQS:Transportsqsmongodbz!kombu.transport.mongodb:Transport zookeeperz#kombu.transport.zookeeper:Transport sqlalchemyz$kombu.transport.sqlalchemy:TransportsqlaSLMQzkombu.transport.SLMQ.Transportslmqz$kombu.transport.filesystem:Transportzkombu.transport.qpid:Transportz'kombu.transport.redis:SentinelTransportz kombu.transport.consul:Transportzkombu.transport.etcd:Transportz,kombu.transport.azurestoragequeues:Transportz)kombu.transport.azureservicebus:Transportzkombu.transport.pyro:Transportz"kombu.transport.gcpubsub:Transport) filesystemqpidsentinelconsuletcdazurestoragequeuesazureservicebuspyrogcpubsubN transport str | NonecCst|trLzt|}Wn5ty@d|vr6d|vr;ddlm}||t}|r/td||td|Yt|SYt|Swt|rH|}t|S|S)zGet transport by name. Arguments: --------- transport (Union[str, type]): This can be either an actual transport class, or the fully qualified path to a transport class, or the alias of a transport. .:r) fmatch_bestz(No such transport: {}. Did you mean {}?zNo such transport: ) isinstancestrTRANSPORT_ALIASESKeyErrorkombu.utils.textr*formatcallabler)r&r*altr r r resolve_transport5s.        r3cCs|tvr t|t|<t|S)zGet transport class by name. The transport string is the full path to a transport class, e.g.:: "kombu.transport.pyamqp:Transport" If the name does not include `"."` (is not fully qualified), the alias table will be consulted. )_transport_cacher3)r&r r r get_transport_clsQs r5)rr)N)r&r'rr') __doc__ __future__rkombu.utils.compatrkombu.utils.importsrr r-r4r3r5r r r r sj