Ë
    UV.j|  ã                  ó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__© ó    údC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\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   