ó Ì g]c@sdZddlZddlZddlmZddlmZddlmZddlmZej e ƒZ dej fd„ƒYZ d e fd „ƒYZd e fd „ƒYZd e fd„ƒYZde fd„ƒYZdej fd„ƒYZd„ZdS(s<Frame objects that do the frame demarshaling and marshaling.iÿÿÿÿN(t amqp_object(t exceptions(tspec(tbytetFramecBs/eZdZdZd„Zd„Zd„ZRS(sÝBase Frame object mapping. Defines a behavior for all child classes for assignment of core attributes and implementation of the a core _marshal method which child classes use to create the binary AMQP frame. RcCs||_||_dS(sCreate a new instance of a frame :param int frame_type: The frame type :param int channel_number: The channel number for the frame N(t frame_typetchannel_number(tselfRR((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyt__init__s cCsBdj|ƒ}tjd|j|jt|ƒƒ|ttjƒS(s]Create the full AMQP wire protocol frame data representation :rtype: bytes ts>BHI( tjointstructtpackRRtlenRRt FRAME_END(Rtpiecestpayload((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyt_marshalscCs t‚dS(sKTo be ended by child classes :raises NotImplementedError N(tNotImplementedError(R((s//srv/kernel/kteam-tools/dashboard/pika/frame.pytmarshal)s(t__name__t __module__t__doc__tNAMERRR(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR s  tMethodcBs&eZdZdZd„Zd„ZRS(s“Base Method frame object mapping. AMQP method frames are mapped on top of this class for creating or accessing their data and attributes. tMETHODcCs#tj|tj|ƒ||_dS(s¡Create a new instance of a frame :param int channel_number: The frame type :param pika.Spec.Class.Method method: The AMQP Class.Method N(RRRt FRAME_METHODtmethod(RRR((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR9scCs>|jjƒ}|jdtjd|jjƒƒ|j|ƒS(sPReturn the AMQP binary encoded value of the frame :rtype: str is>I(RtencodetinsertR R tINDEXR(RR((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyRCs"(RRRRRR(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR2s tHeadercBs&eZdZdZd„Zd„ZRS(s–Header frame object mapping. AMQP content header frames are mapped on top of this class for creating or accessing their data and attributes. RcCs,tj|tj|ƒ||_||_dS(s Create a new instance of a AMQP ContentHeader object :param int channel_number: The channel number for the frame :param int body_size: The number of bytes for the body :param pika.spec.BasicProperties props: Basic.Properties object N(RRRt FRAME_HEADERt body_sizet properties(RRR!tprops((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyRUs cCsD|jjƒ}|jdtjd|jj|jƒƒ|j|ƒS(sPReturn the AMQP binary encoded value of the frame :rtype: str is>HxxQ(R"RRR R RR!R(RR((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyRas"(RRRRRR(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyRNs tBodycBs&eZdZdZd„Zd„ZRS(sŒBody frame object mapping class. AMQP content body frames are mapped on to this base class for getting/setting of attributes/data. R$cCs#tj|tj|ƒ||_dS(s_ Parameters: - channel_number: int - fragment: unicode or str N(RRRt FRAME_BODYtfragment(RRR&((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyRtscCs|j|jgƒS(sPReturn the AMQP binary encoded value of the frame :rtype: str (RR&(R((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR~s(RRRRRR(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR$ms t HeartbeatcBs&eZdZdZd„Zd„ZRS(s¢Heartbeat frame object mapping class. AMQP Heartbeat frames are mapped on to this class for a common access structure to the attributes/data values. R'cCstj|tjdƒdS(s,Create a new instance of the Heartbeat frameiN(RRRtFRAME_HEARTBEAT(R((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyRscCs|jtƒƒS(sPReturn the AMQP binary encoded value of the frame :rtype: str (Rtlist(R((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR“s(RRRRRR(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR'‡s tProtocolHeadercBs/eZdZdZdddd„Zd„ZRS(sqAMQP Protocol header frame class which provides a pythonic interface for creating AMQP Protocol headers R*cCsOd|_|ptjd|_|p/tjd|_|pEtjd|_dS(sÞConstruct a Protocol Header frame object for the specified AMQP version :param int major: Major version number :param int minor: Minor version number :param int revision: Revision iÿÿÿÿiiiN(RRtPROTOCOL_VERSIONtmajortminortrevision(RR,R-R.((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR£s cCs&dtjdd|j|j|jƒS(sReturn the full AMQP wire protocol frame data representation of the ProtocolHeader frame :rtype: str tAMQPtBBBBi(R R R,R-R.(R((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR±sN(RRRRtNoneRR(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyR*œscCs'yK|dd!dkrJtjd|dƒ\}}}dt|||ƒfSWnttjfk rhdSXy&tjd|dd!ƒ\}}}Wntjk r¦dSXtj|tj }|t |ƒkrÑdS||d |!t tj ƒkrt jd ƒ‚n|tj|d !}|tjkrotjd |ƒd} tj| ƒ} | j|dƒ|t|| ƒfS|tjkrÒtjd |ƒ\} } } tj| ƒ}|j|d ƒ}|t|| |ƒfS|tjkrô|t||ƒfS|tjkr|tƒfSt jd|ƒ‚dS(sReceives raw socket data and attempts to turn it into a frame. Returns bytes used to make the frame and the frame :param str data_in: The raw data stream :rtype: tuple(bytes consumed, frame) :raises: pika.exceptions.InvalidFrameError iiR/tBBBiis>BHLiisInvalid FRAME_END markers>Is>HHQi sUnknown frame type: %iN(iN(iN(iN(R t unpack_fromR*t IndexErrorterrorR1tunpackRtFRAME_HEADER_SIZEtFRAME_END_SIZER RRRtInvalidFrameErrorRtmethodstdecodeRR R#RR%R$R(R'(tdata_inR,R-R.RRt frame_sizet frame_endt frame_datat method_idRtclass_idtweightR!R"tout((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyt decode_frame¼s@    (RtloggingR tpikaRRRt pika.compatRt getLoggerRtLOGGERt AMQPObjectRRRR$R'R*RD(((s//srv/kernel/kteam-tools/dashboard/pika/frame.pyts  %