From 3d325d90f27eec8deb644576f752a0c8f72cc4d4 Mon Sep 17 00:00:00 2001 From: Matthias Bodenbenner <bdn@wzl.rwth-aachen.de> Date: Wed, 17 Jun 2020 15:38:14 +0200 Subject: [PATCH] removed badly integrated publisher --- dist/wzl_mqtt-1.1.3-py3-none-any.whl | Bin 4852 -> 0 bytes dist/wzl_mqtt-1.2.0-py3-none-any.whl | Bin 0 -> 4099 bytes setup.py | 2 +- wzl/mqtt/__init__.py | 1 - wzl/mqtt/specialized.py | 45 --------------------------- 5 files changed, 1 insertion(+), 47 deletions(-) delete mode 100644 dist/wzl_mqtt-1.1.3-py3-none-any.whl create mode 100644 dist/wzl_mqtt-1.2.0-py3-none-any.whl delete mode 100644 wzl/mqtt/specialized.py diff --git a/dist/wzl_mqtt-1.1.3-py3-none-any.whl b/dist/wzl_mqtt-1.1.3-py3-none-any.whl deleted file mode 100644 index 3ea642156f20c9403dfda8372234194de6bacd44..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 4852 zcmWIWW@Zs#U|`^2u&$gCaN4)Z_8J2Ng9sA?14y*IDn~!Ju%tvkK0Y%qvm`!Vub{Gb zf^Xg-2cFjN6N}n!E@*Mx=@{OzE~-;Z&tT?`=Fsy#S=Jn1zX&MUE4aQo_x^HqzRj@< zDq+qit9$Iue_A8mcsBcdnB14Yr%oyTStWMb=C_~Bnpe$l*QTd#)L3hAl)>9jKP}MB zx`)MmK_{O=(qGrot<#hI4z79dWI>=$AkV#Tzkl3$Z*FTECU>wVZ*CIH^@Y5}kMw@F zJlni`o6zwae-7{3<}$U^{;_hf!Tj6XL>J1m-3aM_UeF>?TGh3izvA8}R=y7wR!bP$ zr+wgm^|1LJL#cOweds(!L^wECP6#+#smNZ)!N9Osm4QKsfq?-Y4#_#0sd*)O1(k25 zZs$EV`)2F#uhBH1=T7OBnTuXDZ)7X8wr1t}Vw4-KBR11vf$FU^=gCr&HmUP|dT-mV zr1~o9IOj4(v9<C!omS@aelI+;ed(oXYqVxYFKw~3fBdy8;I--W*Pl0kHr|smOXpD3 zuC#B~+o$dM@o)L*)8dyuZ=QN7IxCm`&Fl@+_WUqesJ6Z4^s=^?3I4*Kv%L?N`M7+K zPUDF^EITRph~f6N8LC^Q4^IDKa(dgU6)dL<bWb<zte>&3^}fpKFd4bD%OS>#kMyZt z-m+wtC-;%CBN21IX!vx7Oe^T*367aHf4<<4mfKUNsZMq^YJ2r0Hgl`0=I;rcFBPfs zestO&7PLub`n`;`UlI?*uUdN2RNtSWHd>d}T$=yti**03EPuCiJ-#&MfHjlmOSh%B zzh7In^T7f>C*Fh6ESC1CSxws(WXA7a9>+fU<dS{r-dPfb0h)&%AKo7Iw&Gv|&t~aR ziA6VmcV&kO6!1>^efPBK#;ySO-;c7_=FRYve$*(^k-hRv<F%$cciXQvt@W5zcrtgI zYFp>ko)A&}v?s=^uCvwI?Y{Z=>J@Kk6}H;Q*v9hLZef4U9OQp-ZQ_i{@v8OlhD@Kl zPlwCwk!al}eP_vS1CG5d(q~tsx>_x0s(Jq8zU#q@b|DX(wz9fB=2&=P4%ffkx9hz{ zr>qOhV|-iK$kwp>58Ivk6N~S~wx8zReOEg+rp71l9N$B>Bo@(@j~A+(Z{1M8WK#Fa zW};Ea@suWxBfn4IwOz<GCH#)iw?^q~yO~Q$k9kb6bMy1@2<H3ub*;{gc5{EFYm=mf ze{&sNcW~#0?x=u0-iCq)g<D?Op4=lPt`~4=R)*2LrpGH*PMXQja^B|brn0vNK?l!D z#O;=OzoS`aik9(>ZQD+ku&g-NCJ{R!e}%ys_6weWe9DzKCLCf<k|_+k|7}l_k6fsl z?d1NOn!1eZHhQ%Lq#u%-FSIFe!iRW0^Q$vgOqDzpHi>(K@DX2~&1u^%2^~7(V#j1~ zop)!@>PeZ^w=ZRdm|tjEe(iF>8teTpCf~S}dQkG<9v;oJ2EDuI?);lja{k0T-QH9A zGh!{2&vqCp#oRLpOA~lwz3s=Vr-jZJ7By&fcy3L*S=;sWLWkU`19f3D&KTU@E~jAb zWapx^d6tvyA+0S6liAMtv{g*#bZum+z8D<Ll{fk1^T{s-cHE8YE&KYZilb$!)Xh3O z&-&mPHMuWW|5UXkxxd+ayJFcZt~m+|S?hfJE2<6B!rslj)^^OcP4>=_e4Pr9?2mpf z*9{%-wWu*(uDxv7)B5CM&fL{rBI`uCI@z@z-2E#fclP0S&mF!c-~LMcUflM##OC1l zs6|WKh1-2*zml6>sC34W?dOkMSvzHeF1v^M#5mMAtu&8YKB+0nN?F@+qs>d3Ytl#7 zoI9E17$<jAf4a8mrr7sFKKVP3^mV+kJQBK&tL^;c-M=%fww2F4|LW1pD;%W`&fSw5 zB5F-}PG4TSZqchF3g2xHdY#wbwtkgu_18U>XHwX6zP>sb%YQi{o?rKSAn%0oNqaUw zDLQP@Y&T7CceucnV;`0#1l(QG_{W@mMY-64xTTDjwx`^2sD2;4wC(JgXU%(;A7tZ} z%DkS{Ty|pZDw)}*6839dwd38g-{a)}2M?#+bDB^rAXX%hq0wXO6TheLMZ)XVk>`H! zz5Jmm6cy)NCJ}7CjMw*M^uarC7A;x&fIHs!r}W*V>TYgp)$|i8_c#1uo65H-GpCM0 zK}_=K*{N)K+uqu?cjfbZ;V`c{u-X0bN5*Emn@jt56x%49J@dGwmUpYK=j`KlHaC-m zNao{WGUwXs{hQ9)bGrTg>AA|@=1hffxtipDGmj~Ce-ozNIkdz4{l-rdgEpjYm22rz z=Q#J~F1MIFbBZ+oBn|&?kr@dUeYtnm28e9?A2;*pX~}Q@rkvhoUhmQ`ba|cnh5CeU zuKRudT@NF7ZQFj@$UsKh+5PH<=T0rMmi7^vidXDf<_7!R{UG}yY1i-hcFyTnJyy$2 zcsYel+s?xJUhGWXEt@M-`ESH(ryB2<kY4hBO0D<yii0QEb#HrJp8S;MUY%I3U-`!m z!p2UIob>~GI(2WIKJhWDe~qkd(zcExJ=urOuM^<+I&}H-_v5GS6+b-w^Y}WS^2}cW zWj9^3!}yiMieyZq>K`Qr%IkVO?(YzP@~VpAQl9DQl>*);ekQlCsXscA$v(ok*ZPnA z#TU-crFw0Ji%kn38t-h&DKTv<m>E+Zwa3jr{-0!3)uvhh>X)zb_+B`xEc9oEY~7lZ zA7`vF)Sq=BwvXY_ay>KqaH0D(KPSKOp8mzr&_d(q%$0)sGmdk*m&b_4Djt?zX{~?N z=FL6JdooiC>}}Q+Pm!8C@7?XSY4aC8+rIMil(Z*P4%t`iEL-!--O}pY>c@PlA9u_- znQ|uN^1}CpUu=D!&QhIw>aKZc|0U7=b~m~GH-1}j_3_{9*7in^zwH$||L!Ma%Pw8X z&F3FRy!>%EV$PqR?<B4lefRqIGj`MMGMU-kX(_yUtk=%P?0$AXp&(7nUgIR6ukT{l z<)PJcZ|(nk{$z0Q{_B;eRLr%4T|R#ddgxg9qJEEyfy4P%c9Ny{Y%LlrrO$7%Y1+-O z?23@v=U)5bEcH_xH?uCVE8DUl?5l{J2fzDYg^M<GtS#=j$6aSyzG7DI*J^jB1OE#Z zX8z$=`#Y}q`@VfQzu&EuF8#r__W9X|@$7x4I#tpXAN-G2F25i6$@Gix)MLkP{%=;y zy*BAs*xa|f&qyZ(Eq7*{+c|Sm{Um+An?GNNg=|`QLvlve)<-)(@1Axq+2mu$B=yqw z?`&1~eg5>S<8I96wYN43`pfq%U%Vxj&;5g=OZA1r7vKCpEd23c()Wz#GSjXHUlIK0 zH076$Oy1#4*XfUvSGnHLtvQ-e_+460LhZIpMOn;!S><0<*H%i|Cbp|S=0`M8j+Ge% zOt=x#+{eJcu#t&@K@7Qpl3J0RT2PXipI59`Q0aZnQ%5iC11}F};aU$rU5%4x&R^!x zI;(y1jBlx~)+zl<TOK_PVrZIj#iaGek28DDO!`sL`{>FX6Is@^M;3iaQdl}QmM`gG zNE5>*&MKBIAB#Q~sW!(7#>@(t6ElUgj3r_<Ti5Or#avy2M|K~zwAa@+tyG9*y2MoO zo8;#glvMQ1q20?NGsrKk@R$P|Cj-I<8>%M+{5yNq!kCGHVHz6)gE+DeiVIScGZS+% zt5Q?+3M$uz9PGPnAh0+5m3_|<#dAW3z8zY4tEfqt<H)_R&?m<(uZ=w3my}+vePqA! zV-*w5*a#LolXcI}&aQkc`Fd5EFM}#GTkON4g}a;A-@ExV>HZF`LmRJs6RSFG9ozPF zk@?f57c&kg{QmIs*RSB+#<%1*Bwi>AlzM4fqshM_syVAkU~>J-Ssxv|AIfz(May<M zRhazd=_xK{TXj{7`Tpd!$$FA8C!Srq{QS|o#_}`Fe`m3rNS`Bn`_AttXIAWaaAHFz z=NVsTr4+es>K*r*9krL8_`}y9w?uPK>*>H*>Zi6nn=SBiiO63?<ztW5R4+Jj`0P`A z^AbHbBON=oL$xJkQ|{g~P4KYKuogD<?v7A>Jv$-qMyWOHq_|`ERAlsTHhr6t(2?jE zWojCiYw<f$BW|JPJj<u0`o7(B;~uRvkeTDPEqUSNs|wlwrfr#$v8gY}*h7i^Z}0v0 z&utf9+VxuU;?IvdPgbqX((f=on^3BzWj8H?y+YppR^$Y^XGdkie2oq7eE57NxYRqd z=Z>UEEbA8D8xtm^%(i=YI6LTTL`g+umgK*{jHV^`wC0A^89!eZXY1d0%zo*+`Xhgj zGwpxS)XH3T_WZ-7<KM5JS|6#I`{umtrQXZRivp%O-VbiG?Q-0$EX|y6tt)URXF{Fw zF6Mtms)nkw`Ya@;O!?8hvGd&Xce~|38CJ<uiIursu>SvXQrPsDGroMWdv<4btKxaL zjuYRyZeH5+UFFuv!lkE=@ou}m;gI>wCx5-`k<!`b>Inf4jO~A3W?*2@XJlYdgru{0 zP?tv6P|r}$ST7~BxI{NIFD+l+*EPh^#WBRu*Z-v7VFQ7^zqOw+Z&-TZtojNI1;;~| zn4WtYt!2OY_{zL3P3zS=mde~;w0+AGi$#lS7Y12&w-;ZZ!6#g4QRg!I+p1^&*)fmx z&Q$qvp5EPFdPqXCC|-=iS<F>zn(P9H-#cy|F!??)d%-3HWf7?k{*XC4Pj<d(*}e41 z&fRa{#akDfW}i5Exa$e8us&maVY^QHg+*BjYc`xx_ViZ@srxfcsOZatnEFe4(;u#r zF^xE)IAO=cGqU_DU*qpPyWD*?$?uHt+jPB<x2EA=4H8e>|9*D;;TisjoCgXKw{-rM zi3|)3AS{P3M8Z8>U46LEd-$Hc$m^}Eb?(gh%|QlNj2}EL@;~dX>!ov2e^Zc$*GV0{ zPJMRGpbG{UjLj|@UwZPC>(qJui(hrF@oMOLojvKZDM&+8%lGM1E>EBBK^iMeuAM!7 z-utTWnbl98K6=W87F}HF;mg?=7#LU>7#P&>Ij$tXAU-FxEHy{3q@qN7{i%oOCT%+s z5!T1Zz>vtqz#xy$q###k{~(vr3wz5p889$h*n6Hy!(}ng{f3Sx7Xz=5m?Dv;BW?dh zCM^Gd>tL{W`~$x2Z+|N2wn_*bGE(CR>}n5D7tiJS9~l@bn_XAS;vH~ZV0-toiit1n z?uN_GYIHt%Ci~T;&GQv9dA9U_%WR!<(Pxjx-<|i;z8TKDwfoM5qu<4p&qgj0-g<le z@z5N8!MW83>`b1hy%gyAuW_q&i-6AgSK{kf9PF|*oVJNMRPTIs-BKa^v%yLQy-jyl zD*jqzW^VG%U1-j$`l#3o6Jjl1XMQ=f^V}}UiNUHR=A}0l+D9gGUp~OSan_w_+0Xm( z|J|IkbW^;y)|^A}{eP-9ty;kqpcKYEGqup}M#Mft^P0z+%kSpyyyM@U5zKNU$8F(y z*Q$j@bLMSh-1`2;=~EvX^j33uCve<5e0*xErN8L`$9@I3z__yI*50;ie?CntG&J6S zi(%TG{=Y82-*~sE)_#%`t#q`=)d+V{pJy>Q_HfH?$D+<ezU8&=>Rvf7IDPl#+~Tk5 z`Nr$49-I{qcb3|_y?olsx6dYh`6wUY&B!DI9)iF=Fu?!?+ZsU(c=sG>m;%`ZY+ZVg zJ`mp4$iaxMgO98qTa63S3&PtPS8^ihN2!02&A?XYf%Jp$w#IBOBr{NJKx9Ke*%!S) z0~r9q+Zr$PfDOT4yrCP1UK)Um0^x0qPkHee2QC}X%|g$-Aag)?TVoR+9<xxgGP;@Q k*%)LV2ybCLgU?JzrVj9C1r;U?91I)`?o12}(*;0U0qDngjQ{`u diff --git a/dist/wzl_mqtt-1.2.0-py3-none-any.whl b/dist/wzl_mqtt-1.2.0-py3-none-any.whl new file mode 100644 index 0000000000000000000000000000000000000000..28d6ffd23e342e7972e8316012e5d24e42df39af GIT binary patch literal 4099 zcmWIWW@Zs#U|`^2sIog5z<b!e<{$$D!(&DU29RiZRgQjcVM&R8e0*kJW=VX!UO{E= zgwuRY1_G|%RsJ}ev&Ec{-=VbY(h+w1fLR;;-Y_p${`h&RR)?C(yJz$680WI(KJIM& z7`6Cv<|MU37NOJgM5QV|r&Ok`KXcQ@*KgjMlz*$%R!>Xc9K&`rBT?>%)0ram_KObO zX;XAt6iTN*x|L^Gsm--RJ40eGH&guo+wWFqT@6+|Y(C?g*L#^29bqo>7X55qcK7jG zzOD^F7e{#|XRXwm?|v-d*6q7l%@1ud9{;gyH{$3!zP#dl!!m95fQH;08wP}zohv5< zoUK%3FXUigSggvxAjH7H0QYioPG)LeiC#hFTdCW5kIlZ>I{a%i4d}U3dS&LK7tI^l z%B-zfxxN_X2J48;bXcHzE6sVb)TB-7yr16NwkxT=N;=NDj8SZ@d`_p8`Mlo?&um|M zY1$gCnbAvIEbSkE?Fx8pI{o$M&7Y0;q|DMe6tyeuoAvf-dw%>|e)_cd<<Fa^UW(4j zWq&h!!?Zm=OcttbuQ|P}EoOqhu;*;=gJnK0-=oubVh_ts$~|JZeQk#7R_TM&f0&%! zwrT~-=>px;4Lj>+>}$QRaym>#F70xN@!}(Ws+YGcndQlSB<x7U+%FnFogvc-I(dR) zX3d{3_@m|alxeDyU5(maJ&DcSs;c>W!sbgws=Oba_J;*+l9_%lW9^s31M#bto;20> zXQ++VWi^-PzxpEGe=E!1?Ocy9O*vrAr1{cq>Fw{=mhF77fX|8dU^I)R{b^Rywgs8- zyO+nYPd>S1pSpLJL}7sDp~r`}N4>2$*ub+{I#goO&EH+wVFCrblYZYlZMv~5!2S25 z?6r9_{G=Z>igaYJJkxls>CWBut4(V?rWKydou=B>d9^1*R6p&B@v7@=b#}XNKE8Uz zTUv#!HZr!c{Iy%ypEC#fUtF6wV{*J|eY_#lC-2kYGJ7Oiw@Kewa@&AoZ;SNV6{)UP z3z}-4Ke_LE@S<JF1E;O5E{{1DUYNu6Z};tbZ_z31!txm37B;dqtp3Axr~bs^d$H}O zd3WE{j*Y4D$vemQkS&QtwB_T4D(71_)GwLTy|S5TRB}9}iQ~xc(|2tbGEE7;BlN9N zI@@mMlG0-y6YSjld_02r{(W7mbEDndU+LN;Y2n{o2iG0kd7(QhV2`(<;6dS*7q%z& zNQvtOT$+_(^sedgij|XQ^0S<`IlHOstwGSivl4N;W!~>-)|sMZd}G_TlO-%Gj<rd| zPRL(ju!jAD=O3SP<&6o4*pp-m!|s3EljI{8s%AU6|E8uc<GPJrEdl9=<mL-)3Y_pE zUeEmM%oS55PlZk5-XMI$S7&qDwo5{Xj=0z{8C>Vx8MJy*X7%k$Ss~^Z8kS$XT(HJ^ z|BJ~tE~OrnJh+EP^Q=Md?zubvCX}2%F;BPmRQ`-u3+1yNhDtH_48qa`-dJz@@#<-z z^MyqXS{<HS({9#wJ-yH&cj`c0*o-p<x3|kFm^<0IC~cnQWP3<!i^62Kvp#JV6FOZR znW`@a2Xp03KKXp|OMxAC<9f@!eyZYVnJRU&&d#$wI7UtG%hf+sElKWg_TH{o_KItc z!a~+M-~NhfgS4=BbFZ}>vu%^Tb0lA<!Xx{mpUZVa$9pYmjF)RK8}_t5xtKF|wU@{` zQLavQtp|7i%E+C4xZQJyZ^^g662BL>{VlOM_&sXTl6K*CpV_bEW)~`*ab)}X<5t#A z*`UkrVLmYqHBKwd<Cafqin3DHcHC(5(&n1<ku~Q|COO8*-PE71ZMrG;y^v4-&Le#t zZ!C|5uH$MuKY91>Osj3>bI-qe^zsTvse^O(q=txEQ=Ze8m#$m%>WIR3+k;-`^|!5G zWn2AqPvw~u_MES;4#x6dj)>>i{T|3Wp?uPw%}<IBn>5=^6WkpxaOK#Cr3nFdS2X@H zXJ1h+b|7vk<E8B>cO0tUM=xzVyXIN*-sK0`xTP|$XEm3dSi4GQ_Nj#ZT379Ox9s;g z`TxPgY4@Ba6bpzI31n#W*!slp>3fmzdUfQvAAB!=XbMHe`IbopTQB4FJsExQ&YML` zmOkK)H~uMoH>tXt+gdgKgv$L5f7qt-ZOY84V^9#2JbHF2Ti&*}w(VW{JYP7>s}5{- zfBccL+3x1j{vE|O%4W|zZmH$n>gzfCxSh?-Bq5UdxR}hj_Im%O^Y)x>e}8(evbQ-? zAzZE|x!=rVO5NXtX?G6oFn_=C)5M?+saxe*y3{$&y}8RR=FXfV%|A)QKU`!+LPcNh zowWfX+y2MRJbGI4+rKHNcbV6_^b1{Hr+%S6p_}V|pMTfG$X(mEpEfd((ROyfy5YG~ zi>#%6gr?#ZyOz1ZK6gLJzDU~jd%m4>`c;qBauZ%oVbiv=u)Y^NlXuJJ%2fUvvD&G| z`z558yq{9*y}jb#33lDvUY937Ww}=;mg`sk@q@6j(<5j7fSyj>Tc=Na%<5kwYn!yK z<48~Tq4Vnm_`MEY{`~#;X?w*FkN-Tr&Zj){S3ucK*X%HU<**_d)2RAKiGlLE9*_Gw z#GkyXVz`uNdU~aR_lcj$?Q80fPGqu=Fz&VfBY*LQ^K+?QTj65U!iUB?+j2@w8w+N} zlt=Ax^N;^0Syi=Z*1!7Yt319J&MFK2Ss`1u=H$m2YYg>gU5M>tc(h#4%syP`e$CIx zZ@i~}aWu5h_&IZ>;Qox`obKf@qOppHrB_<(U$uF2&+?wk)B<~(b;VPp=FWR}du`hM zh0nIH{5&P?$&^F(6+6q;{BpOn`nLKppX$dQb55q53Aw!Rec=~d->0)w=bpN29@>9N zbidtAZvTznR$P7j_qw&c(c^D>h0eeG$=I?>S90_DhY>G-9FCat=jS_#>qXzazWt2d zbh}Juc6V9|ZyxKlb1}Q0-A^b;6SLPi$>;04*mZem_1s(g|DHb?9K8Q}<tY_&tzehW zAA=q`*1f3T<6_`&{*|3%={;ME221JlTWp$kGc3Cz<o3DOzBo($)W*%M3+&3aEC~B5 zBIm*H{#W6m%^Yisd+u@9nU=4Z)%&&Do$0{;LWP-sIM)7-EB?N3-_7rLYo$wnu&sT5 z_F+7G->FWOG{p!1qm|3=2YxdBB0Tljv77&!6?3mmIu<tf?d~(u2|>%9+2(f6oK!za z-|yzn*I^->7T%DYk+t>F&d<B2-Agw47&1w{^!+<q)qS5oz3R9dvw7{Uje`F2eajbb ziRE+u;OJ6);qb*b{|^g)Jec%7<GIYV>%mt9|2a+hr6ZGfIMa3dqvTbt_j7BGW)yyx z){{`XEmKhzb6-~ZSJkzZQnrchs*m{*4U}VL1_2Xp#5DIYFfeRnVqg$MZlI)AB&QaX zWaj4;>lIXbpYznw3;V#!!&$i2!%tV^<eBrAIke7dpFHDRs;hNM|I(I6PlFhmrd%;; z{qf_>o->nvRP;W&GRH)gb?uQwUy>A-PL1VDIvCQ#u!*yZWy{B+k437@v4SzPLgvIw z;Vff`Sk2b8`$REUm*A1zM=kC3^-U`kVwo;6mHQ_7`2{5veRF8{a>xwwODjC)z{ZKx z#M<tBGC*vS#fr-e3=H~=3=E18AH;)NmAZy{MtTN%DVfD3x|w-t`TD-DA&xGNA&$QO zC;bi^2<-i>{fv2oYxNgSEk2J47cMb9_cXfF{H8F=KkDFh;UhtP`4^+5f@A_N+6Awi zbM){fU7zkwn>luieAz=kFW0?uDR$P|DMHiA`ER!vIz3r;M&OrDmyS-gLu1<J+XpR5 zCuT1&GG-Qe)!831XXn|@HyyusK3TapTRtwT*f#UT(ZgL&c!ke1#upyf5x=k?D`Cxs zQ_P<3N+ETBrU?~&nGjQcZQZkn>*kn59I>0Qqw$RGca^X4_pKJ~dp7CZ8D&{Dy^y!O z;a?4sPTc=~cKzWQ{)jjQg@{`^|H?!L1_lt8!xtjq9<HuF+~+-f&tBy9*3~+9=KSU$ zgDb`lo)-C^_15*$IjO%X$iwTTj$WreyJpY@gA2xH7mY7HdCGO_y#B?nI@fqLbiK}= z^w|`op{eEj^eLC8&-NgV6(-lto<8q=)%VQmCr=+eWkQQCuJrKbYzzzxEDQ_`YWN&i zl3x&?lUkOVqgPT<qP_mqLv)k8O;X;(Gcqs;GBGg7<1;D9)!9GDrS#0nvQ-8Q3>Rwm zvl<9EMwT@4gq~8EEMjKKw{S^si(=@5*Y{r@`n>C7-GRO5OA6mw#4ET+9TJ>$%Twaj z;ze2OSN2uMtz<cIdG>Ynw&y&%m?d8NGEI3>H7~~XUjA#xJ8xQ^O6|KNe|@IVoe%bx zWB7g_JG*+Tw6XIO``<c2HqUoWI{qZ~t+u$!4X%aNI~MvoUSIHQ|Dnf{+vjXZ`*FEc zplhd4tWvn9$@g6A{l*=B&l0a@N8UanZ@$F3`Q_uRIIde!|L<OSuXbvZ65~rJHoZy9 zlDO~t@t*eRb&r`Qz3sDOPMYGWBEu7#7ZeITe<oXZptf|T(9hHP?pyV96&x7mAOCr6 z+uq|*DMw{8BTEwR{`ly+PVr%;x#^VrGw-VxmYS@+6m|1#>=e#luPRSPc5CcQ)cQEl zzG#o-+-xb4uNyDT*fuY6!)3-RM>q25XiZlBdbO@);nO)hi9i4J<r??sI#&E-5AbGW z5&?JXuy^(tpkP}ghym{hA$9$bO~BT70_g+cZH=EHu?^`w!h2H4`mq&lAiW^Gt#Jw` zQcnz}phGqTl$Fp67m$7s-qsk#1vUeJQG;$Add>tH1;X1JGq~{>2hOMHW}#;!kU1c{ wt&x=nk69?$3f)ZfECn(TgtsvI<1-VI!2-NlK^dEYoq?T!iHU*XH7`gj080)PP5=M^ literal 0 HcmV?d00001 diff --git a/setup.py b/setup.py index d76d6b6..ce0e0ee 100644 --- a/setup.py +++ b/setup.py @@ -1,7 +1,7 @@ from setuptools import setup, find_packages setup(name='wzl-mqtt', - version='1.1.3', + version='1.2.0', url='', author='Benjamin Montavon, Matthias Bodenbenner', author_email='m.bodenbenner@wzl.rwth-aachen.de', diff --git a/wzl/mqtt/__init__.py b/wzl/mqtt/__init__.py index 221ffbd..f479582 100644 --- a/wzl/mqtt/__init__.py +++ b/wzl/mqtt/__init__.py @@ -11,4 +11,3 @@ from .exceptions import PublishError as PublishError from .client import MQTTPublisher from .client import MQTTReceiver -from .specialized import ScheduledMQTTPublisher diff --git a/wzl/mqtt/specialized.py b/wzl/mqtt/specialized.py deleted file mode 100644 index d6c68fa..0000000 --- a/wzl/mqtt/specialized.py +++ /dev/null @@ -1,45 +0,0 @@ -import datetime -import json -from typing import Dict - -from .client import MQTTPublisher - - -class ScheduledMQTTPublisher(MQTTPublisher): - - def __init__(self, loop, duid, schedule: Dict, *args, **kwargs): - MQTTPublisher.__init__(self, duid, *args, **kwargs) - self._loop = loop - self._schedule = schedule - if len(self._schedule.keys()) > 0: - self._update() - - def _update(self): - now = datetime.datetime.now() - next = None - for luid in self._schedule: - data = self._schedule[luid] - if data['next'] is not None and data['next'] <= now: - try: - value = data['method']() - ret = {'uuid': luid, 'value': value} - self.publish(luid, json.dumps(ret), 1) - except Exception as e: - pass - - try: - if callable(data['interval']): - data['next'] = now + datetime.timedelta(seconds=data['interval']()) - else: - data['next'] = now + datetime.timedelta(seconds=data['interval']) - except Exception as e: - # if the next time for publishing can not be set, deactivate publising by setting 'next' to None - data['next'] = None - - if next is None or (data['next'] is not None and data['next'] < next): - next = data['next'] - - if next is None: - next = now + datetime.timedelta(seconds=10) - - self._loop.call_later((next - now).seconds + (next - now).microseconds / 1e6, self._update) \ No newline at end of file -- GitLab