)Jf@ , 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 ZdS )zBHI) joinstructpackr
r lenr r FRAME_END)r piecespayloads r
_marshalzFrame._marshal sY ((6""{64?D4G w<<) )+2359$.5I5IJ 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
sU
D- - -J J J" " " " "r r c " e Zd ZdZdZd Zd ZdS )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 | t j | || _ dS )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 }| dt j d| 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 sN ##%%
aT4;+<==>>>}}V$$$r Nr r r r r! r r r" r r
r$ r$ 2 sC D % % % % %r r$ c " e Zd ZdZd Zd Zd ZdS )HeaderzHeader frame object mapping. AMQP content header frames are mapped
on top of this class for creating or accessing their data and attributes.
c n t | t j | || _ || _ dS )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 }| dt j d| j j | j | | S )r* r z>HxxQ)r6 r, r- r r r. r5 r r/ s r
r zHeader.marshala s\ ''))
v{7DO$94>JJ L L L}}V$$$r Nr0 r" r r
r2 r2 N sC D
% % % % %r r2 c " e Zd ZdZd Zd Zd ZdS )BodyzBody frame object mapping class. AMQP content body frames are mapped on
to this base class for getting/setting of attributes/data.
c ` t | t j | || _ dS )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 8 | | j g S r* )r r= r s r
r z Body.marshal~ s }}dm_---r Nr0 r" r r
r: r: m sC D! ! !. . . . .r r: c " e Zd ZdZd Zd Zd ZdS ) 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 R t | t j d dS )z,Create a new instance of the Heartbeat framer N)r r r FRAME_HEARTBEATr s r
r zHeartbeat.__init__ s!
tT 1155555r c D | t S r? )r listr s r
r zHeartbeat.marshal s }}TVV$$$r Nr0 r" r r
rA rA sC
D6 6 6% % % % %r rA c $ e Zd ZdZd ZddZd ZdS )ProtocolHeaderzqAMQP Protocol header frame class which provides a pythonic interface
for creating AMQP Protocol headers
Nc d| _ |pt j d | _ |pt j d | _ |pt j d | _ dS )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__ sK 6d 3A 6
6d 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 s 1Q3<7 " "%+%7w%J%J "E5(nUE8<<< < #
% ww39= GAaCL4" 4"0^ZZ < ww &3d6III 3w<< w y1}Y&'4+?+???*+EFFF / A
=>JT&&& &tZ88; i(**
j!$$$ & 8888 t( ( ( '-&8&L&L#&) Z)++
23300 & JGGGG t & & $~z:::: t+ + + )++%%
&'?*'L
M
MMs! :> AA !A> >BB)r loggingr pikar r r pika.compatr getLoggerr LOGGER
AMQPObjectr r$ r2 r: rA rG rk r" r r
rr s B B
8 $ $"" "" "" "" ""K " "" "" ""J% % % % %U % % %8 % % % % %U % % %>. . . . .5 . . .4% % % % % % % %* 4 4 4 4 4[+ 4 4 4@LN LN LN LN LNr