
     h[	                        d Z ddlmZ ddlmZmZmZ dZd%dZ	 G d de
          Z G d	 d
e          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d d e          Z G d! d"e          Z G d# d$e
          ZdS )&zExceptions.    )timeout)ChannelErrorConnectionErrorResourceError)reraise
KombuErrorOperationalErrorNotBoundErrorMessageStateErrorTimeoutErrorLimitExceededConnectionLimitExceededChannelLimitExceededr   r   VersionMismatchSerializerNotInstalledr   SerializationErrorEncodeErrorDecodeError	HttpErrorInconsistencyErrorNc                 B    |j         |ur|                    |          |)zReraise exception.)__traceback__with_traceback)tpvaluetbs      L/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/kombu/exceptions.pyr   r      s)    "$$""2&&&
K    c                       e Zd ZdZdS )r   z)Common subclass for all Kombu exceptions.N__name__
__module____qualname____doc__ r   r   r   r      s        3333r   r   c                       e Zd ZdZdS )r	   z/Recoverable message transport connection error.Nr    r%   r   r   r	   r	      s        9999r   r	   c                       e Zd ZdZdS )r   z(Failed to serialize/deserialize content.Nr    r%   r   r   r   r   !   s        2222r   r   c                       e Zd ZdZdS )r   zCannot encode object.Nr    r%   r   r   r   r   %           r   r   c                       e Zd ZdZdS )r   zCannot decode object.Nr    r%   r   r   r   r   )   r)   r   r   c                       e Zd ZdZdS )r
   z:Trying to call channel dependent method on unbound entity.Nr    r%   r   r   r
   r
   -   s        DDDDr   r
   c                       e Zd ZdZdS )r   z*The message has already been acknowledged.Nr    r%   r   r   r   r   1           4444r   r   c                       e Zd ZdZdS )r   zLimit exceeded.Nr    r%   r   r   r   r   5   s        r   r   c                       e Zd ZdZdS )r   z4Maximum number of simultaneous connections exceeded.Nr    r%   r   r   r   r   9   s        >>>>r   r   c                       e Zd ZdZdS )r   z1Maximum number of simultaneous channels exceeded.Nr    r%   r   r   r   r   =   s        ;;;;r   r   c                       e Zd ZdZdS )r   z$Library dependency version mismatch.Nr    r%   r   r   r   r   A   s        ....r   r   c                       e Zd ZdZdS )r   z>Support for the requested serialization type is not installed.Nr    r%   r   r   r   r   E   s        HHHHr   r   c                       e Zd ZdZdS )ContentDisallowedz*Consumer does not allow this content-type.Nr    r%   r   r   r4   r4   I   r-   r   r4   c                       e Zd ZdZdS )r   zData or environment has been found to be inconsistent.

    Depending on the cause it may be possible to retry the operation.
    Nr    r%   r   r   r   r   M   s           r   r   c                   *     e Zd ZdZd fd	Zd Z xZS )r   zHTTP Client Error.Nc                 x    || _         || _        || _        t                                          |||           d S N)codemessageresponsesuper__init__)selfr9   r:   r;   	__class__s       r   r=   zHttpError.__init__W   s:    	 w11111r   c                 ,    d                     |           S )NzHTTP {0.code}: {0.message})format)r>   s    r   __str__zHttpError.__str__]   s    +224888r   )NN)r!   r"   r#   r$   r=   rB   __classcell__)r?   s   @r   r   r   T   sR        2 2 2 2 2 29 9 9 9 9 9 9r   r   r8   )r$   socketr   r   amqpr   r   r   __all__r   	Exceptionr   r	   r   r   r   r
   r   r   r   r   r   r   r4   r   r   r%   r   r   <module>rH      s     * * * * * * = = = = = = = = = =   4 4 4 4 4 4 4 4: : : : :z : : :3 3 3 3 3 3 3 3         $               $      E E E E EJ E E E5 5 5 5 5
 5 5 5    J   ? ? ? ? ?m ? ? ?< < < < <= < < </ / / / /j / / /I I I I IZ I I I5 5 5 5 5. 5 5 5       
9 
9 
9 
9 
9	 
9 
9 
9 
9 
9r   