
    ^f|                        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
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__     T/var/www/html/env/lib/python3.11/site-packages/kombu/asynchronous/aws/sqs/message.pyr   r      s        ;;;;r   r   c                      e Zd ZdZdS )AsyncRawMessagezRaw Message.Nr   r   r   r   r   r      s        r   r   c                      e Zd ZdZd Zd ZdS )AsyncMessagezSerialized message.c                h    t          j        t          |                                                    S )z.Encode/decode the value using Base64 encoding.)base64	b64encoder   decode)selfvalues     r   encodezAsyncMessage.encode   s'    U 3 344;;===r   c                    |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   items     r   __getitem__zAsyncMessage.__getitem__   sJ    ?""&&V^^==??"W__:4.. r   N)r	   r
   r   r   r   r#   r   r   r   r   r      s8        > > >	! 	! 	! 	! 	!r   r   )r   
__future__r   r   kombu.messager   kombu.utils.encodingr   r   r   r   r   r   r   <module>r'      s    ( ( " " " " " "  ! ! ! ! ! ! - - - - - -< < < < <w < < <    &   ! ! ! ! !# ! ! ! ! !r   