ó
öEYc@@s@dZd
dl
mZmZ
d
dlZd
dlZd
dlZd
dlZyd
dl	Z
Wnek
ru


dZ
n
Xd
dl
mZ
d
dlmZ
d
dlmZ
ddlmZmZmZmZ
dd	lmZmZ
dd
lmZ
ddlmZmZm Z 
dd
dddgZ!e"ddgƒ
Z#e"ddgƒ
Z$ej%j&dƒ
ra
d„Z'n	ej(Z'e
ps
eZej)Z*e+ej,j-ddƒƒ
Z.edd4ƒZ/ee0f
ef
d„ƒ
Z1e*d„
Z2d„Z3d e4f
d!„ƒYZ5e5ƒZ6e6j7Z7e6j8Z8e6j9Z9e6j:Z:d"„Z;d#„Z<d$„Z=ej>d
d%krVd&„Z?ne2Z?d'„Z@d(„ZAe<ƒ
e@ƒ
e=ƒ
eAƒ
e6jBd)ƒ

ie<d)6e@d6e=d*6eAd+6e<d,6e=d-6e@d.6eAd/6ZCdd*d+gd0„
ZDd)g
d1„
ZEeEƒ
x*ed2ƒ
D]\ZFZGe9eFjHeGŒ

q
We6jId3„
ZJdS(5uSerialization utilities.i(tabsolute_importtunicode_literalsN(
t
namedtuple(
tcontextmanager(
tBytesIOi
(tContentDisallowedtDecodeErrortEncodeErrortSerializerNotInstalled(treraisettext_t(
tentrypoints(tbytes_to_strtstr_to_bytestbytes_tupickleuloadsudumpsuregisteru
unregisterubinaryu
ascii-8bituapplication/datauapplication/textujavacC@stj
|
ƒ
|ƒ
d
S(Ni(tcodecst
getdecoder(t
ttcoding((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt_decodes
uPICKLE_PROTOCOLiucodecucontent_typeucontent_encodinguencodercc@sVy	dV
WnF|k
r


‚n3|
k
rQ
}
t|||ƒ
t
jƒd
ƒ
n
XdS(Ni(R	tsystexc_info(twrappertincludetexcludetexc((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt_reraise_errors.s
	




cC@s|
t|ƒ
ƒ
S(
N(
R(t
stload((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytpickle_loads9scC@s|rd
||
fS|
S(Nu%s (%s)((tfirsttsecond((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytparenthesize_alias>s
tSerializerRegistrycB@sneZ
dZd
„Zdd„
Zd„Zd„Zd„Zd„Zdd„
Z
deed	„Z
d
„ZRS(u2The registry keeps track of serialization methods.c

C@sOi|_i|_
d|_d|_d|_tƒ|_i|_i|_	dS(
N(
t	_encoderst	_decoderstNonet_default_encodet_default_content_typet_default_content_encodingtsett_disabled_content_typesttype_to_nametname_to_type(
tself((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt__init__Es
	
	
	
	
	

	
uutf-8cC@sV|r"t|||ƒ|j
|
<n|r8||j|<n|
|j|<||j|
<d
S(uêRegister a new encoder/decoder.

        Arguments:
            name (str): A convenience name for the serialization method.

            encoder (callable): A method that will be passed a python data
                structure and should return a string representing the
                serialized data.  If :const:`None`, then only a decoder
                will be registered. Encoding will not be possible.

            decoder (Callable): A method that will be passed a string
                representing serialized data and should return a python
                data structure.  If :const:`None`, then only an encoder
                will be registered.  Decoding will not be possible.

            content_type (str): The mime-type describing the serialized
                structure.

            content_encoding (str): The content encoding (character set) that
                the `decoder` method will be returning. Will usually be
                `utf-8`, `us-ascii`, or `binary`.
        N(tcodecR"R#R*R+(R,tnametencodertdecodertcontent_typetcontent_encoding((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytregisterOs





cC@s0d
|
kr|j|
}
n|j
j|
ƒ

dS(Nu
/(R+R)tdiscard(R,R/((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytenableps


cC@s0d
|
kr|j|
}
n|j
j|
ƒ

dS(Nu
/(R+R)tadd(R,R/((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytdisableus


cC@sŠy]|j|
}|j
j|dƒ
|jj|
dƒ
|jj|dƒ
|jj|
dƒ
Wn&tk
r…


td
j|
ƒ
ƒ
‚
n
XdS(uôUnregister registered encoder/decoder.

        Arguments:
            name (str): Registered serialization method name.

        Raises:
            SerializerNotInstalled: If a serializer by that name
                cannot be found.
        u$No encoder/decoder installed for {0}N(	R+R#tpopR$R"R*tKeyErrorRtformat(R,R/R2((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt
unregisterzs










cC@sPy#|j|
\|_
|_|_Wn&tk
rK


td
j|
ƒ
ƒ
‚
n
XdS(u²
Set the default serialization method used by this library.

        Arguments:
            name (str): The name of the registered serialization method.
                For example, `json` (default), `pickle`, `yaml`, `msgpack`,
                or any custom methods registered using :meth:`register`.

        Raises:
            SerializerNotInstalled: If the serialization method
                requested is not available.
        uNo encoder installed for {0}N(R"R&R'R%R:RR;(R,R/((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt_set_default_serializerŽs
#



c
C@s
|d
krt|
ƒ
S|rG|j
j|ƒ
rGtdj|ƒ
ƒ
‚
n|rjt|
tƒrjdd|
fS|rµt|
tƒrµtt	dd	ƒ


|
j
dƒ
}WdQXdd|fS|rÔ|j
|\}}}n|j}|j}|j
}tt	ƒ

||
ƒ
}WdQX|||fS(
u·Encode data.

        Serialize a data structure into a string suitable for sending
        as an AMQP message body.

        Arguments:
            data (List, Dict, str): The message data to send.

            serializer (str): An optional string representing
                the serialization method you want the data marshalled
                into. (For example, `json`, `raw`, or `pickle`).

                If :const:`None` (default), then json will be used, unless
                `data` is a :class:`str` or :class:`unicode` object. In this
                latter case, no serialization occurs as it would be
                unnecessary.

                Note that if `serializer` is specified, then that
                serialization method will be used even if a :class:`str`
                or :class:`unicode` object is passed in.

        Returns:
            Tuple[str, str, str]: A three-item tuple containing the
            content type (e.g., `application/json`), content encoding, (e.g.,
            `utf-8`) and a string containing the serialized data.

        Raises:
            SerializerNotInstalled: If the serialization method
                requested is not available.
        urawuNo encoder installed for {0}uapplication/dataubinaryRuutf-8Nu
text/plain((t
raw_encodeR"tgetRR;t
isinstanceRR
RRtencodeR%R&R'(R,tdatat
serializertpayloadR2R3R0((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytdumps¡s&









	
	
	


cC@s
|rt|ƒ
nd
}|dk	rT||kr||kr|j|dƒ‚
qn+||jkr|r|j|dƒ‚
n|pˆdjƒ}|
r
|jj|ƒ
}|rÏttƒ

||
ƒ
SWdQXn|t	kr
t
|
tƒr
ttƒ

t|
|ƒSWdQXq
n|
S(u“Decode serialized data.

        Deserialize a data stream as serialized using `dumps`
        based on `content_type`.

        Arguments:
            data (bytes, buffer, str): The message data to deserialize.

            content_type (str): The content-type of the data.
                (e.g., `application/json`).

            content_encoding (str): The content-encoding of the data.
                (e.g., `utf-8`, `binary`, or `us-ascii`).

            accept (Set): List of content-types to accept.

        Raises:
            ContentDisallowed: If the content-type is not accepted.

        Returns:
            Any: The unserialized data.
        uapplication/datau	untrustedudisableduutf-8N(
RR$t_for_untrusted_contentR)tlowerR#R?RRtSKIP_DECODER@R
R(R,RBR2R3taccepttforcet_trusted_contenttdecode((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytloadsàs&

















cC@s.td
j
|t|jj|
|
ƒ|
ƒƒƒ
S(Nu/Refusing to deserialize {0} content of type {1}(RR;R R*R?(R,tctypetwhy((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyRF
s



N(t__name__t
__module__t__doc__R-R4R6R8R<R=R$REtFalsetTRUSTED_CONTENTRMRF(((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyR!Bs
	 				@-c
C@s_d
}
|}t|t
ƒrLd}ttddƒ


|j|ƒ
}WdQXnd}|
||fS(uSpecial case serializer.uapplication/datauutf-8RNubinary((R@R
RRRA(RBR2RDR3((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyR>
s





c
C@s9d
dlm
}
tjd|j|jddddƒ
dS(	u2Register a encoder/decoder for JSON serialization.i(
tjsonujsonR2uapplication/jsonR3uutf-8N(tkombu.utilsRUtregistryR4RERM(
t_json((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt
register_json,
s

cC@sly5d
dl}t
jd|j|jddddƒ
Wn0tk
rg


d„}
t
jdd|
dƒ
n
XdS(	u¸Register a encoder/decoder for YAML serialization.

    It is slower than JSON, but allows for more data types
    to be serialized. Useful if you need to send data such as dates

    iNuyamlR2uapplication/x-yamlR3uutf-8c_@std
ƒ
‚
dS(uŒRaise SerializerNotInstalled.

            Used in case a client receives a yaml message, but yaml
            isn't installed.
            u9No decoder installed for YAML. Install the PyYAML libraryN(
R(targstkwargs((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt
not_availableC
s
(tyamlRWR4t	safe_dumpt	safe_loadtImportErrorR$(R]R\((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt
register_yaml5
s





	ic

C@stt
|ƒ
ƒ
S(
N(RR
(
R((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytunpickleP
s
c
C@s2tj
d
„
}tjd|tddddƒ
dS(upRegister pickle serializer.

    The fastest serialization method, but restricts
    you to python clients.
    cS@s|
|d
tƒ

S(Ntprotocol(
tpickle_protocol(tobjtdumper((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytpickle_dumps]
s
upickleR2uapplication/x-python-serializeR3ubinaryN(tpickleRERWR4Rb(
Rg((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytregister_pickleW
s

c@sÃd}}
yid
dl
}|jdkr_d
dl
m‰m‰

‡f
d†}‡
f
d†}
nd„}|}}
Wn*ttfk
rŸ


d„}|}}
n
Xtjd	||
d
ddd
ƒ
dS(uYRegister msgpack serializer.

    See Also:
        http://msgpack.sourceforge.net/.
    iNi(tpackbtunpackbc

@sˆ|d
tƒ

S(Ntuse_bin_type(
tTrue(
R(
Rj(sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytpackq
s
c

@sˆ|d
dƒ

S(Ntencodinguutf-8((
R(
Rk(sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytunpackt
s
c_@std
ƒ
‚
dS(Nu(msgpack requires msgpack-python >= 0.4.0(
R(RZR[((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytversion_mismatchw
s

c_@std
ƒ
‚
dS(NuKNo decoder installed for msgpack. Please install the msgpack-python library(
R(RZR[((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyR\|
s

umsgpackR2uapplication/x-msgpackR3ubinary(ii(	R$tmsgpacktversionRjRkR`t
ValueErrorRWR4(RnRpRrRqR\((RjRksH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytregister_msgpacke
s 




	

	



ujsonuyamlumsgpackuapplication/jsonuapplication/x-yamluapplication/x-python-serializeuapplication/x-msgpackc
C@s:x3|D]+}
ytj
|
ƒ

Wqtk
r1


qXqWd
S(uíEnable serializers that are considered to be unsafe.

    Note:
        Will enable ``pickle``, ``yaml`` and ``msgpack`` by default, but you
        can also specify a list of serializers (by name or content type)
        to enable.
    N(RWR6R:(tchoicestchoice((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytenable_insecure_serializersž
s






c
C@sRxtj
D]}
tj|
ƒ

q
W|d
k	rNx|D]}
tj|
ƒ

q4Wnd
S(uA
Disable untrusted serializers.

    Will disable all serializers except ``json``
    or you can specify a list of deserializers to allow.

    Note:
        Producers will still be able to serialize data
        in these formats, but consumers will not accept
        incoming data using the untrusted content types.
    N(RWR#R8R$R6(tallowedR/((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytdisable_insecure_serializers­
s





ukombu.serializersc@s$|dk	r ‡f
d
†|Dƒ
S|S(Nc
@s,h|]"}
d|
kr|
nˆ|
’qS(
u
/((t.0t
n(
R+(sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pys	<setcomp>É
s	(
R$(t
lR+((
R+sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pytprepare_accept_contentÇ
s


(ucontent_typeucontent_encodinguencoder(KRRt
__future__RR
RtosRRhtpypickletcPickletcpickleR`R$tcollectionsRt
contextlibRtioRt
exceptionsRRRRtfiveR	R
tutils.compatRtutils.encodingRR
Rt__all__t	frozensetRHRTtplatformt
startswithRRLRtpickle_loadtinttenvironR?RdR.t	ExceptionRRR tobjectR!RWRERMR4R<R>RYRatversion_infoRbRiRuR=t
_setupfunsRxRztepRZR/R+R~(((sH/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/serialization.pyt<module>
s€










"



	
			Ö	
	
	
	
		
					$