UV.jdZddlmZddlZddlmZGddZGddeZGd d eZGd d eZ eee d Z y)zVirtual AMQ Exchange. Implementations of the standard exchanges defined by the AMQ protocol (excluding the `headers` exchange). ) annotationsN) escape_regexc,eZdZdZdZdZdZdZdZy) ExchangeTypezBase class for exchanges. Implements the specifics for an exchange type. Arguments: --------- channel (ChannelT): AMQ Channel. Nc||_yN)channel)selfr s bC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\kombu/transport/virtual/exchange.py__init__zExchangeType.__init__s  ctd)zLookup all queues matching `routing_key` in `exchange`. Returns ------- str: queue name, or 'default' if no queues matched. zsubclass responsibility)NotImplementedError)r tableexchange routing_keydefaults r lookupzExchangeType.lookups"";< @r ) __name__ __module__ __qualname____doc__rr rrr rr r rrs# D=(@r rc eZdZdZdZdZdZy)DirectExchangezTDirect exchange. The `direct` exchange routes based on exact routing keys. directcJ|Dchc] \}}}||k(r|c}}}Scc}}}wrr)r rrrrrkey_rs r rzDirectExchange.lookupAs4(- (-ndAu{"    sc |jj}|jj}|||D] }|||fi|yr)r _lookup_put)r messagerrkwargsr,r-rs r deliverzDirectExchange.deliverGs@,,&&||  X{3E  *6 *4r Nr!r"r#r$rrr0rr r r&r&9s D +r r&c@eZdZdZdZdddZiZdZdZdZ d Z d Z y ) TopicExchangezTopic exchange. The `topic` exchange routes messages based on words separated by dots, using wildcard characters ``*`` (any single word), and ``#`` (one or more words). topicz.*?[^\.]z.*?)*#c d|Dchc]\}}}|j||r|c}}}Scc}}}wr)_match)r rrrrr)patternrs r rzTopicExchange.lookup_s;.3 .3*dGU{{7K0 e   s+c |jj}|jj}|jj}|||Dcgc] }|r||k7r| c}D] } || |fi|ycc}wr)r r,r-deadletter_queue) r r.rrr/r,r- deadletterqrs r r0zTopicExchange.deliveresu,,&&||  \\22 !(;!?0!?AqJ!?0E  *6 *00sA1c*||j||fSr)key_to_patternrs r rzTopicExchange.prepare_bindmsD// z/TopicExchange.key_to_pattern..rs*$ < NN  tT * D"II +D  &r r3c eZdZdZdZdZdZy)FanoutExchangeaFanout exchange. The `fanout` exchange implements broadcast messaging by delivering copies of all messages to all queues bound to the exchange. To support fanout the virtual channel needs to store the table as shared state. This requires that the `Channel.supports_fanout` attribute is set to true, and the `Channel._queue_bind` and `Channel.get_table` methods are implemented. See Also -------- the redis backend for an example implementation of these methods. fanoutc:|Dchc]\}}}| c}}Scc}}wrr)r rrrrr*rs r rzFanoutExchange.lookups )./+!Q///s c p|jjr |jj|||fi|yyr)r supports_fanout _put_fanout)r r.rrr/s r r0zFanoutExchange.delivers7 << ' ' $DLL $ $'; :28 : (r Nr1rr r rTrTs  D0:r rT)r'r4rU) r$ __future__rrMkombu.utils.textrrr&r3rTSTANDARD_EXCHANGE_TYPESrr r r]sZ # )(@(@V+\+*3&L3&l:\:: r