^fdZddlmZddlZddlmZGddZGddeZGd d eZGd d eZ eee d Z dS)zVirtual AMQ Exchange. Implementations of the standard exchanges defined by the AMQ protocol (excluding the `headers` exchange). ) annotationsN) escape_regexc.eZdZdZdZdZdZdZdZdS) ExchangeTypezBase class for exchanges. Implements the specifics for an exchange type. Arguments: --------- channel (ChannelT): AMQ Channel. Nc||_dSN)channel)selfr s R/var/www/html/env/lib/python3.11/site-packages/kombu/transport/virtual/exchange.py__init__zExchangeType.__init__s  c td)zLookup all queues matching `routing_key` in `exchange`. Returns ------- str: queue name, or 'default' if no queues matched. zsubclass responsibility)NotImplementedErrorr tableexchange routing_keydefaults r lookupzExchangeType.lookups"";<< @r ) __name__ __module__ __qualname____doc__rr rrr!rr r rrsf D===(((@@@@@r rc"eZdZdZdZdZdZdS)DirectExchangezTDirect exchange. The `direct` exchange routes based on exact routing keys. directc fd|DS)Nc(h|]\}}}|k |Srr).0rkey_rrs r z(DirectExchange.lookup..Bs4   $dAu{"" """r rrs ` r rzDirectExchange.lookupAs.    (-    r c h|jj}|jj}|||D] }|||fi| dSr)r _lookup_put)r messagerrkwargsr0r1rs r deliverzDirectExchange.deliverGsX,&| WX{33 + +E D * *6 * * * * + +r Nr"r#r$r%rrr4rr r r'r'9sC D   +++++r r'cBeZdZdZdZdddZiZdZdZdZ d Z d Z d S) 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$fd|DS)NcHh|]\}}}||Sr)_match)r+r,patternrrr s r r.z'TopicExchange.lookup..`sC   *dGU{{7K00    r rrs` ` r rzTopicExchange.lookup_s4     .3    r c |jj}|jj}|jjfd|||DD] }|||fi| dS)Nc$g|] }|r|k | Srr)r+q deadletters r z)TopicExchange.deliver..is1000A0 J.r )r r0r1deadletter_queue) r r2rrr3r0r1rrBs @r r4zTopicExchange.deliveres,&| \2 0000;!?!?000 + +E D * *6 * * * * + +r c2||||fSr)key_to_patternrs r rzTopicExchange.prepare_bindmsD// <z/TopicExchange.key_to_pattern..rsI$ $  N  tT * *$ $ $ $ $ $ r z.#*.)joinrsplit)r r,s` r rFzTopicExchange.key_to_patternps^$ $ $ $ $T51177<<$ $ $     r c |j|}n9#t$r,tj|tjx}|j|<YnwxYw||S)zMatch regular expression (cached). Same as :func:`re.match`, except the regex is compiled and cached, then reused on subsequent matches with the same pattern. ) _compiledKeyErrorrecompileUmatch)r r>stringcompileds r r=zTopicExchange._matchwsl  K~g.HH K K K13GRT1J1J JHt~g... K~~f%%%s 3AAN) r"r#r$r%rrIrQrr4rrFr=rr r r7r7Ns D"II   +++DDD    & & & & &r r7c"eZdZdZdZdZdZdS)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. fanoutcd|DS)Nch|]\}}}| Srr)r+r-rs r r.z(FanoutExchange.lookup..s///+!Q///r rrs r rzFanoutExchange.lookups//////r c L|jjr|jj|||fi|dSdSr)r supports_fanout _put_fanout)r r2rrr3s r r4zFanoutExchange.deliversP < ' : $DL $'; : :28 : : : : : : :r Nr5rr r rZrZsC   D000:::::r rZ)r(r8r[) r% __future__rrSkombu.utils.textrrr'r7rZSTANDARD_EXCHANGE_TYPESrr r rds  #""""" ))))))(@(@(@(@(@(@(@(@V+++++\+++*3&3&3&3&3&L3&3&3&l:::::\:::: r