ó O'—^c@@sİdZddlmZddlmZddlZdefd„ƒYZdefd„ƒYZd efd „ƒYZ d efd „ƒYZ ied 6e d6e d6Z dS(s° kombu.transport.virtual.exchange ================================ Implementations of the standard exchanges defined by the AMQ protocol (excluding the `headers` exchange). i(tabsolute_import(t escape_regexNt ExchangeTypecB@s8eZdZdZd„Zd„Zd„Zd„ZRS(sUImplements the specifics for an exchange type. :param channel: AMQ Channel cC@s ||_dS(N(tchannel(tselfR((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyt__init__scC@stdƒ‚dS(stLookup all queues matching `routing_key` in `exchange`. :returns: `default` if no queues matched. ssubclass responsibilityN(tNotImplementedError(Rttabletexchanget routing_keytdefault((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pytlookupscC@s |d|fS(saReturn tuple of `(routing_key, regex, queue)` to be stored for bindings to this exchange.N(tNone(RtqueueRR t arguments((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyt prepare_bind#scC@sJ||dkoI||dkoI||dkoI|p9i|dpFikS(s3Return true if `prev` and `exchange` is equivalent.ttypetdurablet auto_deleteR((RtprevRRRRR((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyt equivalent(sN( t__name__t __module__t__doc__R RRR RR(((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyRs    tDirectExchangecB@s&eZdZdZd„Zd„ZRS(s9The `direct` exchange routes based on exact routing keys.tdirectcC@s,g|D]!\}}}||kr|^qS(N((RRRR R trkeyt_R ((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyR 5scK@sF|jj}|jj}x'|||ƒD]}||||q(WdS(N(Rt_lookupt_put(RtmessageRR tkwargsRRR ((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pytdeliver9s  (RRRRR R (((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyR1s t TopicExchangecB@s[eZdZdZidd6dd6ZiZd„Zd„Zd„Zd „Z d „Z RS( s The `topic` exchange routes messages based on words separated by dots, using wildcard characters ``*`` (any single word), and ``#`` (one or more words).ttopics.*?[^\.]t*s.*?t#cC@s2g|D]'\}}}|j||ƒr|^qS(N(t_match(RRRR R RtpatternR ((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyR Msc K@sw|jj}|jj}|jj}xLg|||ƒD]}|r7||kr7|^q7D]} || ||qYWdS(N(RRRtdeadletter_queue( RRRR RRRt deadlettertqR ((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyR Qs    "cC@s||j|ƒ|fS(N(tkey_to_pattern(RR RR R((sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyRYsc@s3ddj‡fd†t|dƒjdƒDƒƒS(s0Get the corresponding regex for any routing key.s^%s$s\.c3@s$|]}ˆjj||ƒVqdS(N(t wildcardstget(t.0tword(R(sB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pys _ss.#*t.(tjoinRtsplit(RR((RsB/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/exchange.pyR*\s  cC@sRy|j|}Wn1tk rDtj|tjƒ}|j|s !-