Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/__pycache__/ |
a
��Sh2 � @ sH d Z ddlmZ ddlmZ ddlmZ dgZdd� ZG d d� d�Z d
S ) z Amazon SQS queue implementation.� )� annotations)� transform� )� AsyncMessage�
AsyncQueuec C s t | �dkr| d S dS )z4Get the first item in a list, or None if list empty.r r N)�len)�rs� r �J/usr/local/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/queue.py�
list_first s r c @ s e Zd ZdZddefdd�Zdd� Ze Z Z Z Z
Z Z Z
Z Z ZZd0dd �Zd1d
d �Zd2d
d�Zdd� Zd3dd�Zdd� Zd4dd�Zd5dd�Zd6dd�Zd7dd �Zd8d d �Z d d � Z d9d"d#�Z d:d$d%�Z d;d&d'�Z d<d(d)�Z!d=d*d+�Z"d>d.d/�Z#dS )?r zAsync SQS Queue.Nc C s || _ || _|| _d | _d S �N)�
connection�url�
message_class�visibility_timeout)�selfr
r r r r r
�__init__ s zAsyncQueue.__init__c O s
t � �d S r )�NotImplementedError)r �args�kwargsr r r
�_NA s zAsyncQueue._NA�Allc C s | j �| ||�S r )r
Zget_queue_attributes)r �
attributes�callbackr r r
�get_attributes s �zAsyncQueue.get_attributesc C s | j �| |||�S r )r
Zset_queue_attribute)r � attribute�valuer r r r
�
set_attribute% s �zAsyncQueue.set_attribute�VisibilityTimeoutc C s | � |t| j||t��S r �r r �_coerce_field_value�int)r r �_attrr r r
� get_timeout* s
��zAsyncQueue.get_timeoutc C s ||| �S r r )r �key�type�responser r r
r 1 s z AsyncQueue._coerce_field_valuec C s | � d|t| j|��S )Nr )r r �_on_timeout_set)r r r r r r
� set_timeout4 s ��zAsyncQueue.set_timeoutc C s |r
|| _ | j S r )r )r r r r r
r' < s zAsyncQueue._on_timeout_setc C s | j �| ||||�S r )r
�add_permission)r �labelZaws_account_id� action_namer r r r
r) A s
�zAsyncQueue.add_permissionc C s | j �| ||�S r )r
�remove_permission)r r* r r r r
r, G s z AsyncQueue.remove_permissionc C s | j d||tt|�d�S )Nr )�wait_time_secondsr )� get_messagesr r )r r r- r r r r
�readJ s
�zAsyncQueue.readc C s" | j j| |�� |t| j||�d�S �N)r )r
� send_messageZget_body_encodedr �_on_message_sent)r �messageZ
delay_secondsr r r r
�writeR s
�zAsyncQueue.writec C s | j j| ||d�S r0 )r
Zsend_message_batch�r �messagesr r r r
� write_batchX s �zAsyncQueue.write_batchc C s |j |_ |j|_|S r )�id�md5)r Z orig_messageZ new_messager r r
r2 ] s zAsyncQueue._on_message_sentr c C s | j j| |||||d�S )N)Znumber_messagesr r r- r )r
Zreceive_message)r Z num_messagesr r r- r r r r
r. b s �zAsyncQueue.get_messagesc C s | j �| ||�S r )r
�delete_message)r r3 r r r r
r: l s zAsyncQueue.delete_messagec C s | j j| ||d�S r0 )r
�delete_message_batchr5 r r r
r; o s �z AsyncQueue.delete_message_batchc C s | j j| ||d�S r0 )r
� change_message_visibility_batchr5 r r r
r< t s �z*AsyncQueue.change_message_visibility_batchc C s | j j| |d�S r0 )r
Z delete_queue)r r r r r
�deletey s zAsyncQueue.delete�
�ApproximateNumberOfMessagesc C s | j |t| j||t�d�S r0 r )r Z page_sizeZvtimeoutr r" r r r
�count| s
��zAsyncQueue.count)r N)N)Nr )N)N)N)NNN)NN)N)r NNNN)N)N)N)N)r> r> Nr? )$�__name__�
__module__� __qualname__�__doc__r r r Z
count_slow�dumpZ save_to_fileZsave_to_filename�saveZ
save_to_s3Z load_from_s3Zload_from_fileZload_from_filename�load�clearr r r# r r( r' r) r, r/ r4 r7 r2 r. r: r; r< r= r@ r r r r
r sN �����
�
�
�
�N)
rD �
__future__r Zviner r3 r Z_all__r r r r r r
�<module> s