Yohohohohohooho | Sanrei Aya
Sanrei Aya


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__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/__pycache__/queue.cpython-39.pyc
a

��Sh2�@sHdZddlmZddlmZddlmZdgZdd�ZGd	d�d�Z	d
S)z Amazon SQS queue implementation.�)�annotations)�	transform�)�AsyncMessage�
AsyncQueuecCst|�dkr|dSdS)z4Get the first item in a list, or None if list empty.rrN)�len)�rs�r	�J/usr/local/lib/python3.9/site-packages/kombu/asynchronous/aws/sqs/queue.py�
list_firstsrc@seZdZdZddefdd�Zdd�ZeZZZ	Z
ZZZ
ZZZZd0dd	�Zd1d
d�Zd2d
d�Zdd�Zd3dd�Zdd�Zd4dd�Zd5dd�Zd6dd�Zd7dd�Zd8dd�Zdd �Zd9d"d#�Zd:d$d%�Zd;d&d'�Z d<d(d)�Z!d=d*d+�Z"d>d.d/�Z#dS)?rzAsync SQS Queue.NcCs||_||_||_d|_dS�N)�
connection�url�
message_class�visibility_timeout)�selfr
rrr	r	r
�__init__szAsyncQueue.__init__cOs
t��dSr)�NotImplementedError)r�args�kwargsr	r	r
�_NAszAsyncQueue._NA�AllcCs|j�|||�Sr)r
Zget_queue_attributes)r�
attributes�callbackr	r	r
�get_attributes s�zAsyncQueue.get_attributescCs|j�||||�Sr)r
Zset_queue_attribute)r�	attribute�valuerr	r	r
�
set_attribute%s�zAsyncQueue.set_attribute�VisibilityTimeoutcCs|�|t|j||t��Sr�rr�_coerce_field_value�int)rr�_attrr	r	r
�get_timeout*s

��zAsyncQueue.get_timeoutcCs|||�Srr	)r�key�type�responser	r	r
r 1szAsyncQueue._coerce_field_valuecCs|�d|t|j|��S)Nr)rr�_on_timeout_set)rrrr	r	r
�set_timeout4s��zAsyncQueue.set_timeoutcCs|r
||_|jSr)r)rrr	r	r
r'<szAsyncQueue._on_timeout_setcCs|j�|||||�Sr)r
�add_permission)r�labelZaws_account_id�action_namerr	r	r
r)As
�zAsyncQueue.add_permissioncCs|j�|||�Sr)r
�remove_permission)rr*rr	r	r
r,GszAsyncQueue.remove_permissioncCs|jd||tt|�d�S)Nr)�wait_time_secondsr)�get_messagesrr)rrr-rr	r	r
�readJs
�zAsyncQueue.readcCs"|jj||��|t|j||�d�S�N)r)r
�send_messageZget_body_encodedr�_on_message_sent)r�messageZ
delay_secondsrr	r	r
�writeRs
�zAsyncQueue.writecCs|jj|||d�Sr0)r
Zsend_message_batch�r�messagesrr	r	r
�write_batchXs�zAsyncQueue.write_batchcCs|j|_|j|_|Sr)�id�md5)rZorig_messageZnew_messager	r	r
r2]szAsyncQueue._on_message_sentrcCs|jj||||||d�S)N)Znumber_messagesrrr-r)r
Zreceive_message)rZnum_messagesrrr-rr	r	r
r.bs�zAsyncQueue.get_messagescCs|j�|||�Sr)r
�delete_message)rr3rr	r	r
r:lszAsyncQueue.delete_messagecCs|jj|||d�Sr0)r
�delete_message_batchr5r	r	r
r;os�zAsyncQueue.delete_message_batchcCs|jj|||d�Sr0)r
�change_message_visibility_batchr5r	r	r
r<ts�z*AsyncQueue.change_message_visibility_batchcCs|jj||d�Sr0)r
Zdelete_queue)rrr	r	r
�deleteyszAsyncQueue.delete�
�ApproximateNumberOfMessagescCs|j|t|j||t�d�Sr0r)rZ	page_sizeZvtimeoutrr"r	r	r
�count|s

��zAsyncQueue.count)rN)N)Nr)N)N)N)NNN)NN)N)rNNNN)N)N)N)N)r>r>Nr?)$�__name__�
__module__�__qualname__�__doc__rrrZ
count_slow�dumpZsave_to_fileZsave_to_filename�saveZ
save_to_s3Zload_from_s3Zload_from_fileZload_from_filename�load�clearrrr#r r(r'r)r,r/r4r7r2r.r:r;r<r=r@r	r	r	r
rsN�����



�

�


�





�N)
rD�
__future__rZvinerr3rZ_all__rrr	r	r	r
�<module>s

Yohohohohohooho | Sanrei Aya