/usr/lib/python2.6/site-packages/boto/sqs
Edit: /usr/lib/python2.6/site-packages/boto/sqs/message.pyc (12129B)
Ñò
Å-õSc @ sº d Z d d k Z d d k Z d d k l Z d d k l Z d d k l Z d d k l
Z
d e f d „ ƒ YZ d e f d
„ ƒ YZ
d e
f d „ ƒ YZ d
e f d „ ƒ YZ d S( sX
SQS Message
A Message represents the data stored in an SQS queue. The rules for what is allowed within an SQS
Message are here:
http://docs.amazonwebservices.com/AWSSimpleQueueService/2008-01-01/SQSDeveloperGuide/Query_QuerySendMessage.html
So, at it's simplest level a Message just needs to allow a developer to store bytes in it and get the bytes
back out. However, to allow messages to have richer semantics, the Message class must support the
following interfaces:
The constructor for the Message class must accept a keyword parameter "queue" which is an instance of a
boto Queue object and represents the queue that the message will be stored in. The default value for
this parameter is None.
The constructor for the Message class must accept a keyword parameter "body" which represents the
content or body of the message. The format of this parameter will depend on the behavior of the
particular Message subclass. For example, if the Message subclass provides dictionary-like behavior to the
user the body passed to the constructor should be a dict-like object that can be used to populate
the initial state of the message.
The Message class must provide an encode method that accepts a value of the same type as the body
parameter of the constructor and returns a string of characters that are able to be stored in an
SQS message body (see rules above).
The Message class must provide a decode method that accepts a string of characters that can be
stored (and probably were stored!) in an SQS message and return an object of a type that is consistent
with the "body" parameter accepted on the class constructor.
The Message class must provide a __len__ method that will return the size of the encoded message
that would be stored in SQS based on the current state of the Message object.
The Message class must provide a get_body method that will return the body of the message in the
same format accepted in the constructor of the class.
The Message class must provide a set_body method that accepts a message body in the same format
accepted by the constructor of the class. This method should alter to the internal state of the
Message object to reflect the state represented in the message body parameter.
The Message class must provide a get_body_encoded method that returns the current body of the message
in the format in which it would be stored in SQS.
iÿÿÿÿN( t StringIO( t
Attributes( t MessageAttributes( t SQSDecodeErrort
RawMessagec B s€ e Z d Z d d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
d „ Z d
„ Z RS( s
Base class for SQS messages. RawMessage does not encode the message
in any way. Whatever you store in the body of the message is what
will be written to SQS and whatever is returned from SQS is stored
directly into the body of the message.
t c C s\ | | _ | i | ƒ d | _ d | _ d | _ t | ƒ | _ t | ƒ | _ d | _
d S( N( t queuet set_bodyt Nonet idt receipt_handlet md5R t
attributesR t message_attributest md5_message_attributes( t selfR t body( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt __init__S s
c C s t | i | i ƒ ƒ S( N( t lent encodet _body( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt __len__] s c C s. | d j o | i S| d j o | i Sd S( Nt Attributet MessageAttribute( R R
R ( R t namet attrst
connection( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt startElement` s
c C sš | d j o | i | ƒ ny | d j o
| | _ n_ | d j o
| | _ nE | d j o
| | _ n+ | d j o
| | _ n t | | | ƒ d S( Nt Bodyt MessageIdt
ReceiptHandlet MD5OfBodyt MD5OfMessageAttributes( R R R
R R t setattr( R R t valueR ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt
endElementg s
c C s | i | i | i ƒ ƒ ƒ d S( N( R t decodet get_body( R R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt endNodeu s c C s | S( s8 Transform body object into serialized byte array format.( ( R R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR x s c C s | S( s/ Transform seralized byte array into any object.( ( R R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR$ | s c C s
| | _ d S( s@ Override the current body for this object, using decoded format.N( R ( R R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR € s c C s | i S( N( R ( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR% „ s c C s | i | i ƒ ƒ S( sí
This method is really a semi-private method used by the Queue.write
method when writing the contents of the message to SQS.
You probably shouldn't need to call this method in the normal course of events.
( R R% ( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt get_body_encoded‡ s c C s | i o | i i | ƒ Sd S( N( R t delete_message( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt delete s
c C s1 | i o# | i i i | i | i | ƒ n d S( N( R R t change_message_visibilityR
( R t visibility_timeout( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt change_visibility“ s
N( t __name__t
__module__t __doc__R R R R R# R& R R$ R R% R' R) R, ( ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR K s
t Messagec B s e Z d Z d „ Z d „ Z RS( sz
The default Message class used for SQS queues. This class automatically
encodes/decodes the message body using Base64 encoding to avoid any
illegal characters in the message body. See:
https://forums.aws.amazon.com/thread.jspa?threadID=13067
for details on why this is a good idea. The encode/decode is meant to
be transparent to the end-user.
c C s t i | i d ƒ ƒ i d ƒ S( Ns utf-8( t base64t b64encodeR R$ ( R R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR ¥ s c C sD y% t i | i d ƒ ƒ i d ƒ } Wn t i i d ƒ | SX| S( Ns utf-8s Unable to decode message( R1 t b64decodeR R$ t botot logt warning( R R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR$ ¨ s %( R- R. R/ R R$ ( ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR0 ™ s
t MHMessagec B s† e Z d Z d
d
d
d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z
d „ Z d
d „ Z RS( sX
The MHMessage class provides a message that provides RFC821-like
headers like this:
HeaderName: HeaderValue
The encoding/decoding of this is handled automatically and after
the message body has been read, the message instance can be treated
like a mapping object, i.e. m['HeaderName'] would return 'HeaderValue'.
c C sA | d j p
| d j o
h } n t t | ƒ i | | ƒ d S( NR ( R t superR7 R ( R R R t xml_attrs( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR ¼ s
c C s yƒ h } t | ƒ } | i ƒ } x^ | oV | i d ƒ } | d | !} | | d i ƒ } | i ƒ | | i ƒ <| i ƒ } q$ WWn t d | ƒ ‚ n X| S( Nt :i i s Unable to decode message( R t readlinet findt stripR ( R R" t msgt fpt linet delimt key( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR$ Á s
c C s= d } x0 | i ƒ D]" } | d | d | d f } q W| S( NR s %s: %s
i i ( t items( R R" t st item( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR Ð s
c C s
| | i j S( N( R ( R RB ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt __contains__Ö s c C s, | | i j o | i | St | ƒ ‚ d S( N( R t KeyError( R RB ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt __getitem__Ù s c C s! | | i | <| i | i ƒ d S( N( R R ( R RB R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt __setitem__ß s
c C s
| i i ƒ S( N( R t keys( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyRJ ã s c C s
| i i ƒ S( N( R t values( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyRK æ s c C s
| i i ƒ S( N( R RC ( R ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyRC é s c C s
| | i j S( N( R ( R RB ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt has_keyì s c C s$ | i i | ƒ | i | i ƒ d S( N( R t updateR ( R t d( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyRM ï s c C s | i i | | ƒ S( N( R t get( R RB t default( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyRO ó s N( R- R. R/ R R R$ R RF RH RI RJ RK RC RL RM RO ( ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR7 ° s
t EncodedMHMessagec B s e Z d Z d „ Z d „ Z RS( sN
The EncodedMHMessage class provides a message that provides RFC821-like
headers like this:
HeaderName: HeaderValue
This variation encodes/decodes the body of the message in base64 automatically.
The message instance can be treated like a mapping object,
i.e. m['HeaderName'] would return 'HeaderValue'.
c C sT y% t i | i d ƒ ƒ i d ƒ } Wn t d | ƒ ‚ n Xt t | ƒ i | ƒ S( Ns utf-8s Unable to decode message( R1 R3 R R$ R R8 RQ ( R R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR$ s
%c C s7 t t | ƒ i | ƒ } t i | i d ƒ ƒ i d ƒ S( Ns utf-8( R8 RQ R R1 R2 R$ ( R R" ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyR s ( R- R. R/ R$ R ( ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyRQ ö s
( R/ R1 R4 t boto.compatR t boto.sqs.attributesR t boto.sqs.messageattributesR t boto.exceptionR t objectR R0 R7 RQ ( ( ( s4 /usr/lib/python2.6/site-packages/boto/sqs/message.pyt
@ s NF