Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/transport/virtual/__pycache__/base.cpython-39.pyc
Ðазад
a o�h�� � @ s� d Z ddlmZ ddlZddlZddlZddlZddlmZ ddlm Z m Z m Z ddl m Z ddlmZ ddlmZ dd lmZmZ dd lmZ dd lmZ dd lmZmZ dd l m Z ddl m Z ddl m!Z! ddl"m#Z#m$Z$ ddl%m&Z& ddl'm(Z( ddl)m*Z* e�rddl+m,Z, dZ-dZ.dZ/dZ0dZ1dZ2e e3�Z4e d d �Z5e d d �Z6G d d!� d!�Z7G d"d#� d#e8�Z9G d$d%� d%e:�Z;G d&d'� d'�Z<G d(d)� d)�Z=G d*d+� d+e j>�Z>G d,d-� d-�Z?G d.d/� d/e?e j@�ZAG d0d1� d1e jB�ZBG d2d3� d3e jC�ZCdS )4zPVirtual transport implementation. Emulates the AMQ API for non-AMQ transports. � )� annotationsN)�array)� OrderedDict� defaultdict� namedtuple)�count)�Finalize)�Empty)� monotonic�sleep)� TYPE_CHECKING)�queue_declare_ok_t)� ChannelError� ResourceError)� get_logger)�base)�emergency_dump_state)� bytes_to_str� str_to_bytes)� FairCycle��uuid� )�STANDARD_EXCHANGE_TYPES)� TracebackType�HzlMessage could not be delivered: No queues bound to exchange {exchange!r} using binding key {routing_key!r}. zkCannot redeclare exchange {0!r} in vhost {1!r} with different type, durable, autodelete or arguments value.z;Requeuing undeliverable message for queue %r: No consumers.z)Restoring {0!r} unacknowledged message(s)z#UNABLE TO RESTORE {0} MESSAGES: {1}� binding_key_t)�queue�exchange� routing_key�queue_binding_t)r r � argumentsc @ s e Zd ZdZdd� Zdd� ZdS )�Base64z Base64 codec.c C s t t�t|���S �N)r �base64� b64encoder ��self�s� r) ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/transport/virtual/base.py�encodeF s z Base64.encodec C s t �t|��S r# )r$ � b64decoder r& r) r) r* �decodeI s z Base64.decodeN)�__name__� __module__� __qualname__�__doc__r+ r- r) r) r) r* r" C s r" c @ s e Zd ZdZdS )�NotEquivalentErrorzAEntity declaration is not equivalent to the previous declaration.N�r. r/ r0 r1 r) r) r) r* r2 M s r2 c @ s e Zd ZdZdS )�UndeliverableWarningz.The message could not be delivered to a queue.Nr3 r) r) r) r* r4 Q s r4 c @ sV e Zd ZdZdZdZdZddd�Zdd� Zdd� Z d d � Z d d � Z d d� Z dd� Z dS )� BrokerStatez2Broker state holds exchanges, queues and bindings.Nc C s& |d u r i n|| _ i | _tt�| _d S r# )� exchanges�bindingsr �set� queue_index)r' r6 r) r) r* �__init__r s zBrokerState.__init__c C s" | j �� | j�� | j�� d S r# )r6 �clearr7 r9 �r' r) r) r* r; w s zBrokerState.clearc C s |||f| j v S r# )r7 )r' r r r r) r) r* � has_binding| s zBrokerState.has_bindingc C s. t |||�}| j�||� | j| �|� d S r# )r r7 � setdefaultr9 �add)r' r r r r! �keyr) r) r* �binding_declare s zBrokerState.binding_declarec C s@ t |||�}z | j|= W n ty* Y n0 | j| �|� d S r# )r r7 �KeyErrorr9 �remove)r' r r r r@ r) r) r* �binding_delete� s zBrokerState.binding_deletec s: z� j �|�}W n ty" Y n0 � fdd�|D � d S )Nc s g | ]}� j �|d ��qS r# )r7 �pop)�.0Zbindingr< r) r* � <listcomp>� � z5BrokerState.queue_bindings_delete.<locals>.<listcomp>)r9 rE rB )r' r r7 r) r< r* �queue_bindings_delete� s z!BrokerState.queue_bindings_deletec s � fdd�� j | D �S )Nc 3 s$ | ] }t |j|j� j| �V qd S r# )r r r r7 )rF r@ r< r) r* � <genexpr>� s �z-BrokerState.queue_bindings.<locals>.<genexpr>)r9 �r' r r) r< r* �queue_bindings� s �zBrokerState.queue_bindings)N)r. r/ r0 r1 r6 r7 r9 r: r; r= rA rD rI rL r) r) r) r* r5 U s r5 c @ s~ e Zd ZdZdZdZdZdZd dd�Zdd� Z d d � Z d d � Z d d� Z dd� Z dd� Zd dd�Zdd� Zd dd�Zdd� ZdS ) �QoSz�Quality of Service guarantees. Only supports `prefetch_count` at this point. Arguments: --------- channel (ChannelT): Connection channel. prefetch_count (int): Initial prefetch count (defaults to 0). r NTc C sR || _ |p d| _t� | _d| j_t� | _| jj| _| jj | _ t | | j dd�| _ d S )Nr Fr )Z exitpriority)�channel�prefetch_countr � _delivered�restoredr8 �_dirtyr? � _quick_ack� __setitem__� _quick_appendr �restore_unacked_once� _on_collect)r' rN rO r) r) r* r: � s �z QoS.__init__c C s$ | j }| p"t| j�t| j� |k S )z�Return true if the channel can be consumed from. Used to ensure the client adhers to currently active prefetch limits. )rO �lenrP rR �r' Zpcountr) r) r* � can_consume� s zQoS.can_consumec C s, | j }|r(t|t| j�t| j� d�S dS )a� Return the maximum number of messages allowed to be returned. Returns an estimated number of messages that a consumer may be allowed to consume at once from the broker. This is used for services where bulk 'get message' calls are preferred to many individual 'get message' calls - like SQS. Returns ------- int: greater than zero. r N)rO �maxrX rP rR rY r) r) r* �can_consume_max_estimate� s z QoS.can_consume_max_estimatec C s | j r| �� | �||� dS )z&Append message to transactional state.N)rR �_flushrU )r' �message� delivery_tagr) r) r* �append� s z QoS.appendc C s | j | S r# )rP �r' r_ r) r) r* �get� s zQoS.getc C sB | j }| j}z |�� }W n ty. Y q>Y n0 |�|d� q dS )z'Flush dirty (acked/rejected) tags from.N)rR rP rE rB )r' Zdirty� deliveredZ dirty_tagr) r) r* r] � s z QoS._flushc C s | � |� dS )z8Acknowledge message and remove from transactional state.N)rS ra r) r) r* �ack� s zQoS.ackFc C s$ |r| j �| j| � | �|� dS )z4Remove from transactional state and requeue message.N)rN �_restore_at_beginningrP rS �r' r_ �requeuer) r) r* �reject� s z QoS.rejectc C s� | � � | j}g }| jj}|j}|r�z|� \}}W n tyH Y q�Y n0 z ||� W q ty� } z|�||f� W Y d}~q d}~0 0 q |�� |S )z$Restore all unacknowledged messages.N) r] rP rN �_restore�popitemrB � BaseExceptionr` r; )r' rc �errorsZrestoreZ pop_message�_r^ �excr) r) r* �restore_unacked� s &zQoS.restore_unackedc C s� | j �� | �� |du r tjn|}| j}| jr8| jjs<dS t |dd�rT|rPJ �dS zf|r�t t � t | j��|d� | �� }|r�tt|� �\}}t t� t |�|�|d� t||d� W d|_nd|_0 dS )z�Restore all unacknowledged messages at shutdown/gc collect. Note: ---- Can only be called once for each instance, subsequent calls will be ignored. NrQ )�file)�stderrT)rW �cancelr] �sysrq rP �restore_at_shutdownrN � do_restore�getattr�print� RESTORING_FMT�formatrX ro �list�zip�RESTORE_PANIC_FMTr rQ )r' rq �stateZ unrestoredrl �messagesr) r) r* rV s, ��zQoS.restore_unacked_oncec O s dS )a Restore any pending unacknowledged messages. To be filled in for visibility_timeout style implementations. Note: ---- This is implementation optional, and currently only used by the Redis transport. Nr) )r' �args�kwargsr) r) r* �restore_visible2 s zQoS.restore_visible)r )F)N)r. r/ r0 r1 rO rP rR rt r: rZ r\ r` rb r] rd rh ro rV r� r) r) r) r* rM � s rM c s* e Zd ZdZd� fdd� Zdd� Z� ZS )�MessagezMessage object.Nc st || _ |d }|�d�}|r.|�||�d��}t� jf |||d |�d�|�d�|�d�||�d�d d � |�� d S ) N� properties�body� body_encodingr_ � content-type�content-encoding�headers� delivery_info�utf-8) r� rN r_ � content_type�content_encodingr� r� r� Z postencode)�_rawrb � decode_body�superr: )r' �payloadrN r� r� r� �� __class__r) r* r: A s$ � �zMessage.__init__c C sJ | j }| j�| j|�d��\}}t| j�}|�dd � ||| j| j |d�S )Nr� � compression)r� r� r� r� r� ) r� rN � encode_bodyr� rb �dictr� rE r� r� )r' �propsr� rm r� r) r) r* � serializableS s � �zMessage.serializable)N)r. r/ r0 r1 r: r� � __classcell__r) r) r� r* r� > s r� c @ s\ e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z ddd�Z dd� Z dS )�AbstractChannelz�Abstract channel interface. This is an abstract class defining the channel methods you'd usually want to implement in a virtual channel. Note: ---- Do not subclass directly, but rather inherit from :class:`Channel`. Nc C s t d��dS )z Get next message from `queue`.z$Virtual channels must implement _getN��NotImplementedError)r' r �timeoutr) r) r* �_geto s zAbstractChannel._getc C s t d��dS )zPut `message` onto `queue`.z$Virtual channels must implement _putNr� )r' r r^ r) r) r* �_puts s zAbstractChannel._putc C s t d��dS )z!Remove all messages from `queue`.z&Virtual channels must implement _purgeNr� rK r) r) r* �_purgew s zAbstractChannel._purgec C s dS )z<Return the number of messages in `queue` as an :class:`int`.r r) rK r) r) r* �_size{ s zAbstractChannel._sizec O s | � |� dS )z�Delete `queue`. Note: ---- This just purges the queue, if you need to do more you can override this method. N�r� )r' r r r� r) r) r* �_delete s zAbstractChannel._deletec K s dS )z�Create new queue. Note: ---- Your transport can override this method if it needs to do something whenever a new queue is declared. Nr) �r' r r� r) r) r* � _new_queue� s zAbstractChannel._new_queuec K s dS )z�Verify that queue exists. Returns ------- bool: Should return :const:`True` if the queue exists or :const:`False` otherwise. Tr) r� r) r) r* � _has_queue� s zAbstractChannel._has_queuec C s |� |�S )z-Poll a list of queues for available messages.)rb )r' �cycle�callbackr� r) r) r* �_poll� s zAbstractChannel._pollc C s | � |�}|||� d S r# )r� )r' r r� r^ r) r) r* �_get_and_deliver� s z AbstractChannel._get_and_deliver)N)N) r. r/ r0 r1 r� r� r� r� r� r� r� r� r� r) r) r) r* r� c s r� c @ s� e Zd ZdZeZeZdZee�Z dZ de � iZ dZ ed�ZdZdZdZdZd Zd d � Zdgd d�Zdhdd�Zdidd�Zdjdd�Zdd� Zdkdd�Zdldd�Z dmd d �Z dnd d �Z d d!� Z d"d#� Z d$d%� Z!d&d'� Z"d(d)� Z#d*d+� Z$d,d-� Z%dod.d/�Z&dpd0d1�Z'dqd2d3�Z(drd4d5�Z)dsd6d7�Z*d8d9� Z+d:d;� Z,dtd<d=�Z-dud>d?�Z.d@dA� Z/dBdC� Z0dvdDdE�Z1dFdG� Z2dwdHdI�Z3dxdJdK�Z4dLdM� Z5dydNdO�Z6dzdPdQ�Z7dRdS� Z8dTdU� Z9dVdWdXdYdZ�d[d\�Z:e;d]d^� �Z<e;d_d`� �Z=e;dadb� �Z>d{dcdd�Z?dedf� Z@dS )|�Channelz�Virtual channel. Arguments: --------- connection (ConnectionT): The transport instance this channel is part of. TFr$ r N)r� �deadletter_queuer � c s� |� _ t� � _d � _i � _g � _d � _d� _� fdd�� j� � D �� _� � � � _ � j j j }� jD ],}zt� ||| � W q` ty� Y q`0 q`d S )NFc s i | ]\}}||� ��qS r) r) )rF �typ�clsr< r) r* � <dictcomp>� s z$Channel.__init__.<locals>.<dictcomp>)� connectionr8 � _consumers�_cycle� _tag_to_queue�_active_queues�_qos�closed�exchange_types�items�_get_free_channel_id� channel_id�client�transport_options�from_transport_options�setattrrB )r' r� r� Ztopts�opt_namer) r< r* r: � s" � zChannel.__init__�directc C s� |pd}|pd| }|rH|| j jvrDtd�|| jjjp8d�ddd��dS zD| j j| }| �|��||||||�s�t t �|| jjjp�d���W n. t y� ||||p�i g d �| j j|< Y n0 dS ) zDeclare exchange.r� zamq.%sz*NOT_FOUND - no exchange {!r} in vhost {!r}�/��2 � �Channel.exchange_declare�404N)�type�durable� auto_deleter! �table) r} r6 r ry r� r� � virtual_host�typeofZ equivalentr2 �NOT_EQUIVALENT_FMTrB ) r' r r� r� r� r! �nowait�passive�prevr) r) r* �exchange_declare� s6 �� �� �r� c C s: | � |�D ]\}}}| j|ddd� q | jj�|d� dS )z'Delete `exchange` and all its bindings.T)� if_unused�if_emptyN)� get_table� queue_deleter} r6 rE )r' r r� r� �rkeyrm r r) r) r* �exchange_delete s zChannel.exchange_deletec K sj |p dt � }|rF| j|fi |��sFtd�|| jjjp8d�ddd��n| j|fi |�� t|| � |�d�S )zDeclare queue.z amq.gen-%sz'NOT_FOUND - no queue {!r} in vhost {!r}r� r� �Channel.queue_declarer� r ) r r� r ry r� r� r� r� r r� )r' r r� r� r) r) r* � queue_declare s ��r� c K sj |r| � |�rdS | j�|�D ]:\}}}| �|��||||�}| j||g|�R i |�� q | j�|� dS )z Delete queue.N)r� r} rL r� � prepare_bindr� rI ) r' r r� r� r� r r r �metar) r) r* r� s � zChannel.queue_deletec C s | � |� d S r# )r� rK r) r) r* � after_reply_message_received' s z$Channel.after_reply_message_received� c C s t d��d S )Nz(transport does not support exchange_bindr� �r' � destination�sourcer r� r! r) r) r* � exchange_bind* s zChannel.exchange_bindc C s t d��d S )Nz*transport does not support exchange_unbindr� r� r) r) r* �exchange_unbind. s zChannel.exchange_unbindc K s~ |pd}| j �|||�r dS | j �||||� | j j| �dg �}| �|��||||�}|�|� | jrz| j |g|�R � dS )z.Bind `queue` to `exchange` with `routing key`.z amq.directNr� ) r} r= rA r6 r> r� r� r` �supports_fanoutZ _queue_bind)r' r r r r! r� r� r� r) r) r* � queue_bind2 s � zChannel.queue_bindc sh | j �|||� z| �|�}W n ty2 Y d S 0 | �|��||||�� � fdd�|D �|d d �< d S )Nc s g | ]}|� kr|�qS r) r) )rF r� �Z binding_metar) r* rG P rH z(Channel.queue_unbind.<locals>.<listcomp>)r} rD r� rB r� r� )r' r r r r! r� r� r) r� r* � queue_unbindC s �zChannel.queue_unbindc s � fdd�� j jD �S )Nc 3 s. | ]&}� � |�D ]\}}}|||fV qqd S r# )r� )rF r r� �patternr r< r) r* rJ S s �z(Channel.list_bindings.<locals>.<genexpr>�r} r6 r< r) r< r* � list_bindingsR s �zChannel.list_bindingsc K s | � |�S )z%Remove all ready messages from queue.r� r� r) r) r* � queue_purgeW s zChannel.queue_purgec C s t � S r# r r< r) r) r* �_next_delivery_tag[ s zChannel._next_delivery_tagc K sB | � |||� |r.| �|�j|||fi |��S | j||fi |��S )zPublish message.)�_inplace_augment_messager� Zdeliverr� )r' r^ r r r� r) r) r* � basic_publish^ s ��zChannel.basic_publishc C sJ | � |d | j�\|d< }|d }|j|| �� d� |d j||d� d S )Nr� r� )r� r_ r� �r r )r� r� �updater� )r' r^ r r r� r� r) r) r* r� h s � ��z Channel._inplace_augment_messagec sJ |�j |< �j�|� � ��fdd�}|�jj|< �j�|� ��� dS )zConsume from `queue`.c s* �j | �d�}�s"�j�||j� � |�S )N�rN )r� �qosr` r_ )� raw_messager^ �r� �no_ackr' r) r* � _callback{ s z(Channel.basic_consume.<locals>._callbackN)r� r� r` r� � _callbacksr� r? � _reset_cycle)r' r r� r� � consumer_tagr� r� r) r� r* � basic_consumev s zChannel.basic_consumec C sd || j v r`| j �|� | �� | j�|d�}z| j�|� W n tyN Y n0 | jj�|d� dS )z Cancel consumer by consumer tag.N) r� rC r� r� rE r� � ValueErrorr� r� )r' r� r r) r) r* � basic_cancel� s zChannel.basic_cancelc K sF z.| j | �|�| d�}|s*| j�||j� |W S ty@ Y n0 dS )z+Get message by direct access (synchronous).r� N)r� r� r� r` r_ r )r' r r� r� r^ r) r) r* � basic_get� s zChannel.basic_getc C s | j �|� dS )zAcknowledge message.N)r� rd )r' r_ Zmultipler) r) r* � basic_ack� s zChannel.basic_ackc C s |r| j �� S td��dS )zRecover unacked messages.z'Does not support recover(requeue=False)N)r� ro r� )r' rg r) r) r* � basic_recover� s zChannel.basic_recoverc C s | j j||d� dS )zReject message.�rg N)r� rh rf r) r) r* � basic_reject� s zChannel.basic_rejectc C s || j _dS )zzChange QoS settings for this channel. Note: ---- Only `prefetch_count` is supported. N)r� rO )r' Z prefetch_sizerO Z apply_globalr) r) r* � basic_qos� s zChannel.basic_qosc C s t | jj�S r# )rz r} r6 r< r) r) r* � get_exchanges� s zChannel.get_exchangesc C s | j j| d S )z%Get table of bindings for `exchange`.r� r� )r' r r) r) r* r� � s zChannel.get_tablec C s6 z| j j| d }W n ty* |}Y n0 | j| S )z.Get the exchange type instance for `exchange`.r� )r} r6 rB r� )r' r �defaultr� r) r) r* r� � s zChannel.typeofc C s� |du r| j }|s |p|gS z | �|��| �|�|||�}W n tyR g }Y n0 |s�|dur�t�ttj ||d��� | � |� |g}|S )z�Find all queues matching `routing_key` for the given `exchange`. Returns ------- list[str]: queue names -- must return `[default]` if default is set and no queues matched. Nr� ) r� r� �lookupr� rB �warnings�warnr4 �UNDELIVERABLE_FMTry r� )r' r r r �Rr) r) r* �_lookup� s$ � � zChannel._lookupc C s@ |j }|�� }d|d< | �|d |d �D ]}| �||� q*dS )z.Redeliver message to its original destination.TZ redeliveredr r N)r� r� r r� )r' r^ r� r r) r) r* ri � s �zChannel._restorec C s | � |�S r# )ri )r' r^ r) r) r* re � s z Channel._restore_at_beginningc C sR |p | j j}| jrH| j�� rHt| d�r6| j| j|d�S | j| j ||d�S t � �d S )N� _get_many�r� ) r� �_deliverr� r� rZ �hasattrr r� r� r� r )r' r� r� r) r) r* � drain_events� s zChannel.drain_eventsc C s t || j�s| j|| d�S |S )z1Convert raw message to :class:`Message` instance.)r� rN )� isinstancer� )r' r� r) r) r* �message_to_python� s zChannel.message_to_pythonc C s> |pi }|� di � |� d|p"| j� ||||p2i |p8i d�S )zPrepare message data.r� �priority)r� r� r� r� r� )r> �default_priority)r' r� r r� r� r� r� r) r) r* �prepare_message� s �zChannel.prepare_messagec C s t d��dS )z�Enable/disable message flow. Raises ------ NotImplementedError: as flow is not implemented by the base virtual implementation. z%virtual channels do not support flow.Nr� )r' Zactiver) r) r* �flow s z Channel.flowc C sp | j sfd| _ t| j�D ]}| �|� q| jr6| j�� | jdurP| j�� d| _| jdurf| j� | � d| _ dS )zTClose channel. Cancel all consumers, and requeue unacked messages. TN) r� rz r� r� r� rV r� �closer� � close_channelr� )r' Zconsumerr) r) r* r s z Channel.closec C s. |r&|� � dkr&| j�|��|�|fS ||fS �Nr� )�lower�codecsrb r+ �r' r� �encodingr) r) r* r� $ s zChannel.encode_bodyc C s& |r"|� � dkr"| j�|��|�S |S r )r r rb r- r r) r) r* r� ) s zChannel.decode_bodyc C s t | j| jt�| _d S r# )r r� r� r r� r< r) r) r* r� . s �zChannel._reset_cyclec C s | S r# r) r< r) r) r* � __enter__2 s zChannel.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | None�None)�exc_type�exc_val�exc_tb�returnc C s | � � d S r# )r )r' r r r r) r) r* �__exit__5 s zChannel.__exit__c C s | j jS )z/Broker state containing exchanges and bindings.)r� r} r< r) r) r* r} = s z Channel.statec C s | j du r| �| �| _ | j S )z&:class:`QoS` manager for this channel.N)r� rM r< r) r) r* r� B s z Channel.qosc C s | j d u r| �� | j S r# )r� r� r< r) r) r* r� I s z Channel.cyclec C sV z$t tt|d d �| j�| j�}W n tttfyB | j}Y n0 |rR| j| S |S )z�Get priority from message. The value is limited to within a boundary of 0 to 9. Note: ---- Higher value has more priority. r� r ) r[ �min�int� max_priority� min_priority� TypeErrorr� rB r )r' r^ �reverser r) r) r* �_get_message_priorityO s �� z Channel._get_message_priorityc C sd t | jj�}td| jjd �D ]"}||vr | jj�|� | S q td�t| jj �| jj�d��d S )Nr z/No free channel ids, current={}, channel_max={})� r� ) r8 r� �_used_channel_ids�range� channel_maxr` r ry rX �channels)r' Zused_channel_idsr� r) r) r* r� c s ��z Channel._get_free_channel_id)Nr� FFNFF)FF)NF)FF)r� r� FN)r� r� FN)Nr� N)Nr� N)F)F)F)F)r r F)r� )N)NN)NNNNN)T)N)N)F)Ar. r/ r0 r1 r� rM ru r� r r� r� r" r r� r Z_delivery_tagsr� r� r r& r% r: r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r� r� r ri re r r r r r r� r� r� r r" �propertyr} r� r� r) r� r) r) r) r* r� � s� � � � � � � � r� c s0 e Zd ZdZ� fdd�Zdd� Zdd� Z� ZS )� Managementz'Base class for the AMQP management API.c s t � �|� |j�� | _d S r# )r� r: r� rN )r' � transportr� r) r* r: w s zManagement.__init__c C s dd� | j �� D �S )Nc S s g | ]\}}}|||d ��qS ))r� r� r r) )rF �q�e�rr) r) r* rG | s �z+Management.get_bindings.<locals>.<listcomp>)rN r� r< r) r) r* � get_bindings{ s �zManagement.get_bindingsc C s | j �� d S r# )rN r r< r) r) r* r s zManagement.close)r. r/ r0 r1 r: r5 r r� r) r) r� r* r0 t s r0 c @ s� e Zd ZdZeZeZeZdZdZ dZ dZ dZ dZ ejjjdeddg�dd�Zd d � Zd d � Zd d� Zdd� Zdd� Zd dd�Zdd� Zdd� Zdd� Zd dd �Z e d d � �Z dS )!� Transportz|Virtual transport. Arguments: --------- client (kombu.Connection): The client this is a transport for. Ng �?i�� Fr� Ztopic)Z asynchronousZ exchange_typeZ heartbeatsc K s\ || _ t� | _g | _g | _i | _| �| j| jt�| _ |j � d�}|d urN|| _ t t�| _d S )N�polling_interval)r� r5 r} r. �_avail_channelsr� �Cycle�_drain_channelr r� r� rb r7 r � ARRAY_TYPE_Hr+ )r' r� r� r7 r) r) r* r: � s zTransport.__init__c C s> z | j �� W S ty8 | �|�}| j�|� | Y S 0 d S r# )r8 rE � IndexErrorr� r. r` )r' r� rN r) r) r* �create_channel� s zTransport.create_channelc C sb zTz| j �|j� W n ty& Y n0 z| j�|� W n tyJ Y n0 W d |_nd |_0 d S r# )r+ rC r� r� r. r� )r' rN r) r) r* r � s zTransport.close_channelc C s | j �| �| �� | S r# )r8 r` r= r< r) r) r* �establish_connection� s z Transport.establish_connectionc C sN | j �� | j| jfD ]2}|rz |�� }W n ty< Y q0 |�� qqd S r# )r� r r8 r. rE � LookupError)r' r� Z chan_listrN r) r) r* �close_connection� s zTransport.close_connectionc C s� t � }| jj}| j}|r(|r(||kr(|}z|| j|d� W q� tyz |d urft � | |krft�� �|d urvt|� Y q(0 q�q(d S )Nr ) r r� rb r7 r r �socketr� r )r' r� r� Z time_startrb r7 r) r) r* r � s zTransport.drain_eventsc C sV |st d�|���z| j| }W n( t yH t�t|� | �|� Y n 0 ||� d S )Nz.Received message without destination queue: {})rB ry r� �logger�warning�W_NO_CONSUMERS�_reject_inbound_message)r' r^ r r� r) r) r* r � s �� zTransport._deliverc C sF | j D ]:}|r|j||d�}|j�||j� |j|jdd� qBqd S )Nr� Tr� )r. r� r� r` r_ r )r' r� rN r^ r) r) r* rE � s z!Transport._reject_inbound_messagec C s0 |r|| j vr td�||���| j | |� d S )Nz,Message for queue {!r} without consumers: {})r� rB ry )r' rN r^ r r) r) r* �on_message_ready s ��zTransport.on_message_readyc C s |j ||d�S )N)r� r� )r )r' rN r� r� r) r) r* r: s zTransport._drain_channelc C s | j dd�S )N� localhost)�port�hostname)� default_portr< r) r) r* �default_connection_params s z#Transport.default_connection_params)N)N) r. r/ r0 r1 r� r r9 r0 r� rJ r. r� r7 r- r r6 Z implements�extend� frozensetr: r= r r> r@ r r rE rF r: r/ rK r) r) r) r* r6 � s6 � r6 )Dr1 � __future__r r$ rA rs r r � collectionsr r r � itertoolsr Zmultiprocessing.utilr r r �timer r �typingr Z amqp.protocolr Zkombu.exceptionsr r Z kombu.logr Zkombu.transportr Zkombu.utils.divr Zkombu.utils.encodingr r Zkombu.utils.schedulingr Zkombu.utils.uuidr r r �typesr r; r r� rD rx r| r. rB r r r" � Exceptionr2 � UserWarningr4 r5 rM r� r� Z StdChannelr� r0 r6 r) r) r) r* �<module> s\ G #%B R
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка