σ O'—^c@@sFdZddlmZddlZddlmZddlmZmZddlmZm Z ddl m Z ddl m Z dd lmZd d lmZydd lmZWn'ek rΫd efd„ƒYZnXdZdZdZdZdZdefd„ƒYZdejfd„ƒYZdejfd„ƒYZdS(s« kombu.transport.mongodb ======================= MongoDB transport. :copyright: (c) 2010 - 2013 by Flavio Percoco Premoli. :license: BSD, see LICENSE for more details. i(tabsolute_importN(terrors(tloadstdumps(t MongoClientt uri_parser(tEmpty(t_detect_environment(t bytes_to_stri(tvirtual(t CursorTypeR cB@seZRS((t__name__t __module__(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyR ss 127.0.0.1i‰itmessagessmessages.routingsmessages.broadcasttBroadcastCursorcB@sMeZdZd„Zd„Zd„Zed„Zd„Zd„Z e Z RS(sCursor for broadcast queues.cC@s||_|jdtƒdS(Ntrewind(t_cursortpurgetFalse(tselftcursor((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt__init__*s cC@s|jjƒ|jS(N(Rtcountt_offset(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pytget_size/scC@s|jjƒdS(N(Rtclose(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyR2scC@sD|r|jjƒn|jjƒ|_|jj|jƒ|_dS(N(RRRRtskip(RR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyR5scC@s|S(N((R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt__iter__=scC@srx\tr^yt|jƒ}Wn;tjjk rY}d|jkrS|jƒqn‚qXPqW|jd7_|S(Nsnot valid at serveri( tTruetnextRtpymongoRtOperationFailuretmessageRR(Rtmsgtexc((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt__next__@s  ( R R t__doc__RRRRRRR#R(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyR's      tChannelcB@sμeZdZeZiZd„Zd„Zd„Z d„Z d„Z d„Z dd„Z d„Zdd „Zd „Zd „Zd „Zd „Zd„Zd„Zd„Zed„ƒZd„Zd„Zd„Zd„Zd„ZRS(cO@s0tt|ƒj||Ži|_|jƒdS(N(tsuperR%Rt_broadcast_cursorst_create_client(Rtvargstkwargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyR[s cK@sdS(N((RtqueueR*((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt _new_queuecscC@s¦||jkrEyt|j|ƒƒ}Wqztk rAd}qzXn5|jƒjdi|d6ditjd6dt ƒ}|dkr’t ƒ‚nt t |dƒƒS(NtqueryR+tsortt_idtremovetpayload( t_fanout_queuesRtget_broadcast_cursort StopIterationtNonet get_messagestfind_and_modifyRt ASCENDINGRRRR(RR+R!((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt_getfs      cC@sB||jkr"|j|ƒjƒS|jƒji|d6ƒjƒS(NR+(R2R3RR6tfindR(RR+((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt_sizexscK@s+|jƒjit|ƒd6|d6ƒdS(NR1R+(R6tinsertR(RR+R R*((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt_put~scC@sR|j|ƒ}||jkr4|j|ƒjƒn|jƒji|d6ƒ|S(NR+(R;R2tget_broadcaset_cursorRR6R0(RR+tsize((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt_purge‚s s mongodb://c C@sw|jj}|j}|j|ƒs1||}n|t|ƒsN|t7}n|jr·d|kr·|jdƒ\}}|j}|jrž|d|j7}n|d|d|}n|j dk rΟ|j nt }t j ||ƒ}|dpχ|j} | d krd} nitd6|jd6|jr?t|jd ƒndd 6} | j|jƒ| j|d ƒ|| | fS( Nt@s://t:tdatabaset/t kombu_defaulttauto_start_requesttssliθtconnectTimeoutMStoptions(RDN(t connectiontclientthostnamet startswithtlent DEFAULT_HOSTtuseridtsplittpasswordtportR5t DEFAULT_PORTRt parse_urit virtual_hostRRGtconnect_timeouttinttupdatettransport_options( RtschemeRKRLtheadttailt credentialsRStparsedtdbnameRI((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt _parse_uriŒs0         &cC@s&tjdkr"|jddƒn|S(NiRF(i(Rt version_tupletpopR5(RRI((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt_prepare_client_options΅sc C@s|jd|ƒ\}}}|j|ƒ}||dξs(t frozensettstatet exchangesR6troutingR:(RR€t localRoutest brokerRoutes((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt get_tableηs  cK@s+|jƒjit|ƒd6|d6ƒdS(sDeliver fanout message.R1R+N(R‚R<R(RR€R R†R*((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/mongodb.pyt _put_fanoutςscC@s€|j|ƒjdkr>|j||||ƒ||j| s*  /κ