h<dZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZd Zd efd efd efd efdefdZdZdZdZGddZGddZGddeZedegddZGddZdS)zBase transport interface.N)RecoverableConnectionError) ChannelErrorConnectionError)Message) dictfilter)cached_property) maybe_s_to_ms)r StdChannel Management Transportz x-expiresz x-message-ttlz x-max-lengthzx-max-length-byteszx-max-priority)expires message_ttl max_lengthmax_length_bytes max_priorityc ttd|D}|r t|fi|n|S)aConvert queue arguments to RabbitMQ queue arguments. This is the implementation for Channel.prepare_queue_arguments for AMQP-based transports. It's used by both the pyamqp and librabbitmq transports. Arguments: arguments (Mapping): User-supplied arguments (``Queue.queue_arguments``). Keyword Arguments: expires (float): Queue expiry time in seconds. This will be converted to ``x-expires`` in int milliseconds. message_ttl (float): Message TTL in seconds. This will be converted to ``x-message-ttl`` in int milliseconds. max_length (int): Max queue length (in number of messages). This will be converted to ``x-max-length`` int. max_length_bytes (int): Max queue size in bytes. This will be converted to ``x-max-length-bytes`` int. max_priority (int): Max priority steps for queue. This will be converted to ``x-max-priority`` int. Returns: Dict: RabbitMQ compatible queue arguments. c3<K|]\}}t||VdSN)_to_rabbitmq_queue_argument).0keyvalues P/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/kombu/transport/base.py z.to_rabbitmq_queue_arguments..6sD C $C//)rdictitems) argumentsoptionsprepareds rto_rabbitmq_queue_argumentsr!se6$!--//H+3 A4 & &X & & & ArcDt|\}}|| ||n|fSr)RABBITMQ_QUEUE_ARGUMENTS)rropttyps rrr=s,',HC e/E U ::rcRtd|j|S)Nz)r1rr3s rprepare_queue_argumentsz"StdChannel.prepare_queue_argumentsasrc|Srr>r;s r __enter__zStdChannel.__enter__ds rc.|dSr)close)r1exc_infos r__exit__zStdChannel.__exit__gs r) __name__ __module__ __qualname____doc__no_ack_consumersr/r6r9r@rBrDrHr>rrr r Is&&/////////   rr ceZdZdZdZdZdS)r z!AMQP Management API (incomplete).c||_dSr) transport)r1rPs r__init__zManagement.__init__ns "rc"t|dr8r:r;s rr9zManagement.get_bindingsqr<rN)rIrJrKrLrQr9r>rrr r ks8++###/////rr c$eZdZdZdZdZdZdS) Implementsz/Helper class used to define transport features.cN ||S#t$rt|wxYwr)KeyErrorAttributeError)r1rs r __getattr__zImplements.__getattr__xs: &9  & & & %% % &s $c|||<dSrr>)r1rrs r __setattr__zImplements.__setattr__~sS rc |j|fi|Sr)r))r1r3s rextendzImplements.extendst~d--f---rN)rIrJrKrLrXrZr\r>rrrTrTusG99&&& .....rrTF)directtopicfanoutheaders) asynchronous exchange_type heartbeatscbeZdZdZeZdZdZdZefZ e fZ dZ dZ dZeZdZdZdZdZd Zd Zdd Zd ZdZdZdZdZejej e!j"e!j#ffdZ$dZ%dZ&dde'de'fdZ(e)dZ*dZ+e,dZ-e)dZ.e)dZ/dS) r zBase class for transports.NFN/Ac ||_dSr)client)r1rgr3s rrQzTransport.__init__s  rc"t|d)Nestablish_connectionr:r;s rrizTransport.establish_connections5666rc"t|d)Nclose_connectionr:r1 connections rrkzTransport.close_connections1222rc"t|d)Ncreate_channelr:rls rrozTransport.create_channels/000rc"t|d)N close_channelr:rls rrqzTransport.close_channels///rc "t|d)N drain_eventsr:)r1rmr3s rrszTransport.drain_eventsr<rcdSrr>)r1rmrates rheartbeat_checkzTransport.heartbeat_check rcdS)Nrer>r;s rdriver_versionzTransport.driver_versionsurcdS)Nrr>rls rget_heartbeat_intervalz Transport.get_heartbeat_intervalsqrcdSrr>r1rmloops rregister_with_event_loopz"Transport.register_with_event_looprxrcdSrr>r~s runregister_from_event_loopz$Transport.unregister_from_event_looprxrcdSNTr>rls rverify_connectionzTransport.verify_connectiontrc4jfdS)Ncjstd dn$#$rYdS$r}|jvrYd}~dSd}~wwxYw||dS)NzSocket was disconnectedr)timeout) connectedrerrno call_soon)rexc_read_unavailrmrserrorrs rrz%Transport._make_reader.._reads' L01JKKK  Q'''''      9((FFFFF  NN5$ ' ' ' ' 's &AA AAA)rs)r1rmrrrrrss ````@@r _make_readerzTransport._make_readersI!.  ( ( ( ( ( ( ( ( ( ( rcdSrr>rls rqos_semantics_matches_specz$Transport.qos_semantics_matches_specrrcf|j}|||x}|_||dSr)_Transport__readerr)r1rmrreaders r on_readablezTransport.on_readables9 >%)%6%6z%B%B BFT]t r**urireturnct)z(Customise the display format of the URI.)r')r1rinclude_passwordmasks ras_urizTransport.as_uris!###rciSrr>r;s rdefault_connection_paramsz#Transport.default_connection_paramss rc,||Sr)r )r1r2r3s r get_managerzTransport.get_managerst$$$rc*|Sr)rr;s rmanagerzTransport.managers!!!rc|jjSr) implementsrcr;s rsupports_heartbeatszTransport.supports_heartbeatss ))rc|jjSr)rrar;s r supports_evzTransport.supports_evs ++r)rt)Fr)0rIrJrKrLr rg can_parse_url default_portrconnection_errorsrchannel_errors driver_type driver_namerdefault_transport_capabilitiesr\rrQrirkrorqrsrwrzr|rrrsocketrrrEAGAINEINTRrrrstrrpropertyrrrrrrr>rrr r s$$JFML)*#_N KKH/6688J777333111000///          06~!<5<2M& $$#$S$$$$X%%%""_"**X*,,X,,,rr )rLrramqp.exceptionsrkombu.exceptionsrr kombu.messagerkombu.utils.functionalrkombu.utils.objectsrkombu.utils.timer __all__intr#r!rr,r r rrT frozensetrr r>rrrs 666666::::::::!!!!!!------//////****** >]+#]3!3'-s3%s+ BBBD;;; $$$ D//////// . . . . . . . . ",)DDDEE"""v,v,v,v,v,v,v,v,v,v,r