gvdZddlmZddlmZmZmZddlmZee Z dZ e dz Z dZ d dZdd Zdd Zdd Zy )z:Native Delayed Delivery API. Only relevant for RabbitMQ. ) annotations) ConnectionExchangeQueue) 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 d/var/www/html/answerous/venv/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.#) r channelrangerrbinddeclarepow 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|}|jj|}|jdk(r$tj d|j dy|jjdr |jnd|j}|jt||j|j |y)z6Binds a queue to the native delayed delivery exchange.directz 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.N#z#.)r$) rrexchangerloggerwarnnamer$ startswithr!r )r"queuerr/r$s r.bind_queue_to_native_delayed_delivery_exchanger5Os  "G JJw E,,W5H}}  i /hi j ','8'8'C'C ( %##u(()* 5;O MM(--[M9rc|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)r joinlist) countdownr$s rcalculate_routing_keyr<asI1}>?? 899 88DId+- .1[M1B BBrN)rintreturnstr)r"rr#r?r>None)r"rr4rr>r@)r;r=r$r?r>r?)__doc__ __future__rkomburrr kombu.logr__name__r0MAX_NUMBER_OF_BITS_TO_USE MAX_LEVELr rr+r5r<rrrIsN#-- H  % ) #< %3:l:$Cr