Ih~ dZddlmZddlmZddlmZd/dZidddd d dd d d ddddddddddddddddddddddd d!d d"d#d$d%d&d'd(d)d*d+ ZiZ d0d1d-Z d0d1d.Z y,)2zBuilt-in transports.) annotations)_detect_environment)symbol_by_namecHtdk(r ddl}yy#t$rYywxYw)z/Return true if :pypi:`librabbitmq` can be used.defaultrNT)r librabbitmq ImportError)rs Q/var/www/html/planif/env/lib/python3.12/site-packages/kombu/transport/__init__.pysupports_librabbitmqr s6 )         s  !!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) filesystemqpidsentinelconsuletcdazurestoragequeuesazureservicebuspyrogcpubsubNcHt|tr2 t|}t|r|}t|St|S|S#t$rSd|vrBd|vr>ddlm}||t}|rt dj||t d|Yt|SwxYw)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_ALIASEScallableKeyErrorkombu.utils.textr(formatr) transportr(alts r resolve_transportr25s)S! ())4I "%K i((~i((  B)#9(<8!)->?"BII%s,--!4YK@AAi(( Bs AAB! B!cH|tvrt|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_cacher2)r0s r get_transport_clsr5Qs(((&7 &B# I &&)returnz bool | None)N)r0 str | Noner7r8) __doc__ __future__rkombu.utils.compatrkombu.utils.importsrr r+r4r2r5r6r r>s+"2.  . 2 0:  @   7  0 . / * *268 2  ,!" ,#$9 ,90 ,HB ,45:8 'r6