o
    	h|                     @  sd   d Z ddlmZ ddlZddlmZ ddlmZ G dd deZG dd	 d	eZ	G d
d deZ
dS )z"Amazon SQS message implementation.    )annotationsN)Message)str_to_bytesc                   @     e Zd ZdZdS )BaseAsyncMessagez1Base class for messages received on async client.N__name__
__module____qualname____doc__ r   r   d/var/www/html/optinet_system/venv/lib/python3.10/site-packages/kombu/asynchronous/aws/sqs/message.pyr          r   c                   @  r   )AsyncRawMessagezRaw Message.Nr   r   r   r   r   r      r   r   c                   @  s    e Zd ZdZdd Zdd ZdS )AsyncMessagezSerialized message.c                 C  s   t t| S )z.Encode/decode the value using Base64 encoding.)base64	b64encoder   decode)selfvaluer   r   r   encode   s   zAsyncMessage.encodec                 C  s4   |dkr| j S |dkr|  S |dkr| jS t|)z(Support Boto3-style access on a message.ReceiptHandleBodyqueue)receipt_handleget_bodyr   KeyError)r   itemr   r   r   __getitem__   s   zAsyncMessage.__getitem__N)r   r	   r
   r   r   r   r   r   r   r   r      s    r   )r   
__future__r   r   kombu.messager   kombu.utils.encodingr   r   r   r   r   r   r   r   <module>   s    