U Íø.eã@srdZddlmZddlZddlmZGdd„dƒZGdd„deƒZGd d „d eƒZGd d „d eƒZ eee d œZ dS)z‚Virtual AMQ Exchange. Implementations of the standard exchanges defined by the AMQ protocol (excluding the `headers` exchange). é)Ú annotationsN)Ú escape_regexc@s4eZdZdZdZdd„Zdd„Zdd„Zd d „ZdS) Ú ExchangeTypez™Base class for exchanges. Implements the specifics for an exchange type. Arguments: --------- channel (ChannelT): AMQ Channel. NcCs ||_dS©N)Úchannel)Úselfr©rúD/tmp/pip-unpacked-wheel-48hrr5dg/kombu/transport/virtual/exchange.pyÚ__init__szExchangeType.__init__cCs tdƒ‚dS)z¡Lookup all queues matching `routing_key` in `exchange`. Returns ------- str: queue name, or 'default' if no queues matched. zsubclass responsibilityN)ÚNotImplementedError©rÚtableÚexchangeÚ routing_keyÚdefaultrrr ÚlookupszExchangeType.lookupcCs |d|fS)zÃPrepare queue-binding. Returns ------- Tuple[str, Pattern, str]: of `(routing_key, regex, queue)` to be stored for bindings to this exchange. Nr©rÚqueuerrÚ argumentsrrr Ú prepare_bind&szExchangeType.prepare_bindcCs8||dko6||dko6||dko6|p*i|dp4ikS)z3Return true if `prev` and `exchange` is equivalent.ÚtypeÚdurableÚ auto_deleterr)rÚprevrrrrrrrr Ú equivalent0s  ÿ þýzExchangeType.equivalent) Ú__name__Ú __module__Ú __qualname__Ú__doc__rr rrrrrrr rs    rc@s$eZdZdZdZdd„Zdd„ZdS)ÚDirectExchangezTDirect exchange. The `direct` exchange routes based on exact routing keys. Údirectcs‡fdd„|DƒS)Ncsh|]\}}}|ˆkr|’qSrr)Ú.0ÚrkeyÚ_r©rrr Ú Bsÿz(DirectExchange.lookup..rr rr$r rAs ÿzDirectExchange.lookupcKs2|jj}|jj}|||ƒD]}|||f|ŽqdSr)rÚ_lookupÚ_put©rÚmessagerrÚkwargsr&r'rrrr ÚdeliverGszDirectExchange.deliverN©rrrrrrr+rrrr r9src@sJeZdZdZdZdddœZiZdd„Zdd „Zd d „Z d d „Z dd„Z dS)Ú TopicExchangezºTopic 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.*?)Ú*ú#cs‡‡fdd„|DƒS)Ncs"h|]\}}}ˆ |ˆ¡r|’qSr)Ú_match)r!r"Úpatternr©rrrr r%`s ÿz'TopicExchange.lookup..rr rr3r r_s ÿzTopicExchange.lookupc sH|jj}|jj}|jj‰‡fdd„|||ƒDƒD]}|||f|Žq0dS)Ncsg|]}|r|ˆkr|‘qSrr)r!Úq©Z deadletterrr Ú isÿz)TopicExchange.deliver..)rr&r'Zdeadletter_queuer(rr5r r+es zTopicExchange.delivercCs|| |¡|fSr)Úkey_to_patternrrrr rmszTopicExchange.prepare_bindcs(dd ‡fdd„t|dƒ d¡Dƒ¡S)z0Get the corresponding regex for any routing key.z^%s$z\.c3s|]}ˆj ||¡VqdSr)Ú wildcardsÚget)r!Úword©rrr Ú rsÿz/TopicExchange.key_to_pattern..z.#*Ú.)ÚjoinrÚsplit)rr"rr;r r7psþzTopicExchange.key_to_patterncCsFz|j|}Wn,tk r:t |tj¡}|j|<YnX| |¡S)z¸Match regular expression (cached). Same as :func:`re.match`, except the regex is compiled and cached, then reused on subsequent matches with the same pattern. )Ú _compiledÚKeyErrorÚreÚcompileÚUÚmatch)rr2ÚstringZcompiledrrr r1ws zTopicExchange._matchN) rrrrrr8r@rr+rr7r1rrrr r-Nsÿr-c@s$eZdZdZdZdd„Zdd„ZdS)ÚFanoutExchangeaþFanout 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. ÚfanoutcCsdd„|DƒS)NcSsh|]\}}}|’qSrr)r!r#rrrr r%—sz(FanoutExchange.lookup..rr rrr r–szFanoutExchange.lookupcKs |jjr|jj|||f|ŽdSr)rZsupports_fanoutZ _put_fanout)rr)rrr*rrr r+™sÿÿzFanoutExchange.deliverNr,rrrr rG„srG)r r.rH) rÚ __future__rrBZkombu.utils.textrrrr-rGZSTANDARD_EXCHANGE_TYPESrrrr Ús  +6ý