IhzdZddlmZddlmZmZmZmZddlm Z e e Z dZ e dz Z dZd dZdd Zdd Zdd Zy )z:Native Delayed Delivery API. Only relevant for RabbitMQ. ) annotations) ConnectionExchangeQueuebinding) get_loggercelery_delayed_deliveryc,|dkr tdd|S)z=Generates the delayed queue/exchange name based on the level.rz#level must be a non-negative numbercelery_delayed_) ValueError)levels `/var/www/html/planif/env/lib/python3.12/site-packages/kombu/transport/native_delayed_delivery.py level_namers" qy>?? UG $$cJ|dk7r|dk7r td|j}d}tdddD]}t|}|dkDrt|dz nd }t |d j |}|j |d td |dz|dkDr|ntd}|dk(rd|d<t||j |} | j | j||d|z}d}tdddD]U}t|}|dkDrt|dz nd }t |d j |} | j||d|z}Wt td j |} | j | jtd|y )z:Declares all native delayed delivery exchanges and queues.classicquorumz+queue_type must be either classic or quorumz1.#rr Ntopic)typezreject-publishi)z x-queue-typez x-overflowz x-message-ttlzx-dead-letter-exchangez at-least-oncezx-dead-letter-strategy)queue_argumentsz*.z0.#) rchannelrangerrbinddeclarepow CELERY_DELAYED_DELIVERY_EXCHANGErbind_to) connection queue_typer routing_keyr current_level next_leveldelayed_exchanger delayed_queuenext_level_exchangedelivery_exchanges r4declare_native_delayed_delivery_exchanges_and_queuesr,sY:#9FGG  "GKr2s#)"5) .3aiZ *T %- &))-g   "'* E]T149AIjCc    !8GO4 5$ +  $w-  m[9[( 3)6Kr1c" )"5) .3aiZ *T (0 W)&&*d7m  ##M;?[(  )#+(w#88<W jm[9rc|j}|j|}t}|jr<|j t |j|j |jn|jr |j}|D]}|jj|}|jdk(r$tjd|jdQ|j jdr |j nd|j }|jt||j|j|y) aBind a queue to the native delayed delivery exchange. When a message arrives at the delivery exchange, it must be forwarded to the original exchange and queue. To accomplish this, the function retrieves the exchange or binding objects associated with the queue and binds them to the delivery exchange. :param connection: The connection object used to create and manage the channel. :type connection: Connection :param queue: The queue to be bound to the native delayed delivery exchange. :type queue: Queue Warning: ------- If a direct exchange is detected, a warning will be logged because native delayed delivery does not support direct exchanges. )r% argumentsdirectz Exchange z is a direct exchange and native delayed delivery do not support direct exchanges. ETA tasks published to this exchange will block the worker until the ETA arrives.#z#.)r%N)rrsetexchangeaddrr%binding_argumentsbindingsrloggerwarningname startswithr"r!)r#queuerr5 binding_entryr2r%s r.bind_queue_to_native_delayed_delivery_exchanger<Os"&  "G JJw E UH ~~ W NN))--  >>! > *3388A ==H $ NNYx}}o6op q 3@3L3L3W3W 4m//=4456 9{S hmm = >rc|dkr td|s tddjt|dd|zS)zRCalculate the routing key for publishing a delayed message based on the countdown.r z#countdown must be a positive numberzrouting_key must be non-empty.028b)rjoinlist) countdownr%s rcalculate_routing_keyrC~sI1}>?? 899 88DId+- .1[M1B BBrN)rintreturnstr)r#rr$rFrENone)r#rr:rrErG)rBrDr%rFrErF)__doc__ __future__rkomburrrr kombu.logr__name__r6MAX_NUMBER_OF_BITS_TO_USE MAX_LEVELr!rr,r<rCrrrPsO#66 H  % ) #< %3:l,>^Cr