
    Ih|                    v    d Z ddlmZ ddlZddlmZ ddlmZ  G d de      Z G d d	e      Z	 G d
 de      Z
y)z"Amazon SQS message implementation.    )annotationsN)Message)str_to_bytesc                      e Zd ZdZy)BaseAsyncMessagez1Base class for messages received on async client.N__name__
__module____qualname____doc__     [/var/www/html/planif/env/lib/python3.12/site-packages/kombu/asynchronous/aws/sqs/message.pyr   r      s    ;r   r   c                      e Zd ZdZy)AsyncRawMessagezRaw Message.Nr   r   r   r   r   r      s    r   r   c                      e Zd ZdZd Zd Zy)AsyncMessagezSerialized message.c                Z    t        j                  t        |            j                         S )z.Encode/decode the value using Base64 encoding.)base64	b64encoder   decode)selfvalues     r   encodezAsyncMessage.encode   s!    U 34;;==r   c                    |dk(  r| j                   S |dk(  r| j                         S |dk(  r| j                  S t        |      )z(Support Boto3-style access on a message.ReceiptHandleBodyqueue)receipt_handleget_bodyr   KeyError)r   items     r   __getitem__zAsyncMessage.__getitem__   sD    ?"&&&V^==?"W_::4. r   N)r	   r
   r   r   r   r#   r   r   r   r   r      s    >	!r   r   )r   
__future__r   r   kombu.messager   kombu.utils.encodingr   r   r   r   r   r   r   <module>r'      s:    ( "  ! -<w <& !# !r   