
     hX                     ~    d 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.    N)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__     ^/var/www/html/Sam_Eipo/venv/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   r   kombu.messager   kombu.utils.encodingr   r   r   r   r   r   r   <module>r%      s    ( (  ! ! ! ! ! ! - - - - - -< < < < <w < < <    &   ! ! ! ! !# ! ! ! ! !r   