>i@ d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ej e
Z G d dej Z
G d d
e
Z G d d e
Z G d
de
Z G d de
Z G d dej Zd Zy)zBHI) joinstructpackr
r lenr r FRAME_END)r piecespayloads r
_marshalzFrame._marshal sU ((6"{{64??D4G4G w<)+2359$..5IJ Jr c t )zKTo be ended by child classes
:raises NotImplementedError
)NotImplementedErrorr s r
marshalz
Frame.marshal) s
"!r N)__name__
__module__ __qualname____doc__NAMEr r r r r
r r
s
D-J"r r c e Zd ZdZdZd Zd Zy)MethodzBase Method frame object mapping. AMQP method frames are mapped on top
of this class for creating or accessing their data and attributes.
METHODc \ t j | t j | || _ y)zCreate a new instance of a frame
:param int channel_number: The frame type
:param pika.Spec.Class.Method method: The AMQP Class.Method
N)r r r FRAME_METHODmethod)r r r( s r
r zMethod.__init__9 s! tT . .? r c | j j }|j dt j d| j j
| j
| S )PReturn the AMQP binary encoded value of the frame
:rtype: str
r >I)r( encodeinsertr r INDEXr r r s r
r zMethod.marshalC sH ##%
aT4;;+<+<=>}}V$$r Nr r r r r! r r r" r r
r$ r$ 2 s D %r r$ c e Zd ZdZd Zd Zd Zy)HeaderzHeader frame object mapping. AMQP content header frames are mapped
on top of this class for creating or accessing their data and attributes.
c j t j | t j | || _ || _ y)a
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)r r r FRAME_HEADER body_size
properties)r r r5 propss r
r zHeader.__init__U s( tT . .?" r c | j j }|j dt j d| j j
| j | j | S )r* r z>HxxQ)r6 r, r- r r r. r5 r r/ s r
r zHeader.marshala sR '')
v{{7DOO$9$94>>J L}}V$$r Nr0 r" r r
r2 r2 N s D
%r r2 c e Zd ZdZd Zd Zd Zy)BodyzBody frame object mapping class. AMQP content body frames are mapped on
to this base class for getting/setting of attributes/data.
c \ t j | t j | || _ y)z_
Parameters:
- channel_number: int
- fragment: unicode or str
N)r r r
FRAME_BODYfragment)r r r= s r
r z
Body.__init__t s tT__n=
r c : | j | j g S r* )r r= r s r
r z Body.marshal~ s }}dmm_--r Nr0 r" r r
r: r: m s D!.r r: c e Zd ZdZd Zd Zd Zy) HeartbeatzHeartbeat frame object mapping class. AMQP Heartbeat frames are mapped
on to this class for a common access structure to the attributes/data
values.
c N t j | t j d y)z,Create a new instance of the Heartbeat framer N)r r r FRAME_HEARTBEATr s r
r zHeartbeat.__init__ s
tT 1 115r c 4 | j t S r? )r listr s r
r zHeartbeat.marshal s }}TV$$r Nr0 r" r r
rA rA s
D6%r rA c " e Zd ZdZd ZddZd Zy)ProtocolHeaderzqAMQP Protocol header frame class which provides a pythonic interface
for creating AMQP Protocol headers
Nc d| _ |xs t j d | _ |xs t j d | _ |xs t j d | _ y)zConstruct 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
r N)r
r PROTOCOL_VERSIONmajorminorrevision)r rM rN rO s r
r zProtocolHeader.__init__ sP 6d 3 3A 6
6d 3 3A 6
BHL rJ zInvalid FRAME_END markerr+ z>HHQ NzUnknown frame type: %i)r unpack_fromrG
IndexErrorerrorunpackr FRAME_HEADER_SIZEFRAME_END_SIZEr r r r InvalidFrameErrorr' methodsdecoder$ r4 r7 r2 r< r: rC rA )data_inrM rN rO r
r
frame_size frame_end
frame_data method_idr( class_idweightr5 r6 outs r
decode_framerk s5 1Q<7 "%+%7%7w%J "E5(nUE8<< < #39== GAaL4"0^Z &&3d6I6III 3w< y1}Y'4+??**+EFF // A
>JT&&& &&tZ8; i(*
j!$ & 888 t(( ( '-&8&8&L#&) ZZ)+
230 & JGGG t & $~z::: t++ + )+%%
&
&'?*'L
MM}
% << s" 1G5 H 5HHH*)H*)r loggingr pikar r r pika.compatr getLoggerr LOGGER
AMQPObjectr r$ r2 r: rA rG rk r" r r
rr s B
8 $""K " " ""J%U %8 %U %>.5 .4% %* 4[++ 4@LNr