ง w‡งใ/ำใ๓R—ddlmZddlZddlmZerddlmZGd„deฆซZGd„deej ฆซZ Gd „d eฆซZ Gd „d eฆซZ Gd „deฆซZ Gd„de ฆซZ Gd„de ฆซZGd„deฆซZGd„deฆซZGd„deฆซZGd„deฆซZGd„deฆซZGd„deฆซZGd„d eฆซZGd!„d"eฆซZGd#„d$eฆซZGd%„d&eฆซZGd'„d(eฆซZGd)„d*eฆซZGd+„d,e ฆซZGd-„d.eฆซZGd/„d0eฆซZGd1„d2eฆซZGd3„d4eฆซZGd5„d6eฆซZ Gd7„d8eฆซZ!Gd9„d:eฆซZ"Gd;„ds(€€€€€๐2๐2๐2๐2๐2๐2r r/c๓—eZdZdd„ZdS)ฺSecureConnWantedErrorrrc๓—dS)Nz%nats: secure connection not availabler rs r rzSecureConnWantedError.__str__D๓€ุ6ะ6r Nrrr r r r2r2C๓(€€€€€๐7๐7๐7๐7๐7๐7r r2c๓—eZdZdd„ZdS)ฺSecureConnFailedErrorrrc๓—dS)Nznats: secure connection failedr rs r rzSecureConnFailedError.__str__I๓€ุ/ะ/r Nrrr r r r7r7H๓(€€€€€๐0๐0๐0๐0๐0๐0r r7c๓—eZdZdd„ZdS)ฺBadSubscriptionErrorrrc๓—dS)Nznats: invalid subscriptionr rs r rzBadSubscriptionError.__str__N๓€ุ+ะ+r Nrrr r r r<r<M๓(€€€€€๐,๐,๐,๐,๐,๐,r r<c๓—eZdZdd„ZdS)ฺBadSubjectErrorrrc๓—dS)Nznats: invalid subjectr rs r rzBadSubjectError.__str__S๓€ุ&ะ&r Nrrr r r rArAR๓(€€€€€๐'๐'๐'๐'๐'๐'r rAc๓—eZdZd d „Zdd „Zd S)ฺSlowConsumerErrorฺsubjectrฺreplyฺsidฺintฺsubrrฺNonec๓>—||_||_||_||_dSฉN)rGrHrIrK)rrGrHrIrKs r ฺ__init__zSlowConsumerError.__init__Xs"€ุˆŒ ุˆŒ ุˆŒุˆŒˆˆr c๓6—d|j›d|j›d|j›S)Nz/nats: slow consumer, messages dropped subject: z, sid: z, sub: )rGrIrKrs r rzSlowConsumerError.__str__^s*€ุqภฤะqะqะVZิV^ะqะqะgkิgoะqะqะqr N) rGrrHrrIrJrKrrrLrฉrr r rOrr r r rFrFWsB€€€€€๐๐๐๐๐ r๐r๐r๐r๐r๐rr rFc๓—eZdZdd„ZdS)ฺBadTimeoutErrorrrc๓—dS)Nznats: timeout invalidr rs r rzBadTimeoutError.__str__crCr Nrrr r r rSrSbrDr rSc๓—eZdZdd„ZdS)ฺAuthorizationErrorrrc๓—dS)Nznats: authorization failedr rs r rzAuthorizationError.__str__hr>r Nrrr r r rVrVgr?r rVc๓—eZdZdd„ZdS)ฺNoServersErrorrrc๓—dS)Nz)nats: no servers available for connectionr rs r rzNoServersError.__str__mrr Nrrr r r rYrYlrr rYc๓—eZdZdd„ZdS)ฺJsonParseErrorrrc๓—dS)Nz%nats: connect message, json parse errr rs r rzJsonParseError.__str__rr4r Nrrr r r r\r\qr5r r\c๓—eZdZdd„ZdS)ฺMaxPayloadErrorrrc๓—dS)Nznats: maximum payload exceededr rs r rzMaxPayloadError.__str__wr9r Nrrr r r r_r_vr:r r_c๓—eZdZdd„ZdS)ฺDrainTimeoutErrorrrc๓—dS)Nz#nats: draining connection timed outr rs r rzDrainTimeoutError.__str__|s€ุ4ะ4r Nrrr r r rbrb{s(€€€€€๐5๐5๐5๐5๐5๐5r rbc๓—eZdZdd„ZdS)ฺConnectionDrainingErrorrrc๓—dS)Nznats: connection drainingr rs r rzConnectionDrainingError.__str__s€ุ*ะ*r Nrrr r r rere€s(€€€€€๐+๐+๐+๐+๐+๐+r rec๓—eZdZdd„ZdS)ฺConnectionReconnectingErrorrrc๓—dS)Nznats: connection reconnectingr rs r rz#ConnectionReconnectingError.__str__†๓€ุ.ะ.r Nrrr r r rhrh…s(€€€€€๐/๐/๐/๐/๐/๐/r rhc๓—eZdZdd„ZdS)ฺInvalidUserCredentialsErrorrrc๓—dS)Nznats: invalid user credentialsr rs r rz#InvalidUserCredentialsError.__str__‹r9r Nrrr r r rlrlŠr:r rlc๓—eZdZdd„ZdS)ฺInvalidCallbackTypeErrorrrc๓—dS)Nz+nats: callbacks must be coroutine functionsr rs r rz InvalidCallbackTypeError.__str__s€ุ<ะr‡s๐๐#ะ"ะ"ะ"ะ"ะ"เ€€€ุ ะ ะ ะ ะ ะ เ๐3ุ2ะ2ะ2ะ2ะ2ะ2๐ ๐ ๐ ๐ ๐ ˆI๑ ๔ ๐ ๐๐๐๐๐5˜'ิ.๑๔๐๐ ;๐;๐;๐;๐;˜๑;๔;๐;๐ (๐(๐(๐(๐(˜5๑(๔(๐(๐ 6๐6๐6๐6๐6˜u๑6๔6๐6๐ &๐&๐&๐&๐&ะ(๑&๔&๐&๐ %๐%๐%๐%๐%˜ ๑%๔%๐%๐ )๐)๐)๐)๐)˜E๑)๔)๐)๐ 2๐2๐2๐2๐2˜e๑2๔2๐2๐ 7๐7๐7๐7๐7˜E๑7๔7๐7๐ 0๐0๐0๐0๐0˜E๑0๔0๐0๐ ,๐,๐,๐,๐,˜5๑,๔,๐,๐ '๐'๐'๐'๐'e๑'๔'๐'๐ r๐r๐r๐r๐r˜๑r๔r๐r๐'๐'๐'๐'๐'e๑'๔'๐'๐ ,๐,๐,๐,๐,˜๑,๔,๐,๐ ;๐;๐;๐;๐;U๑;๔;๐;๐ 7๐7๐7๐7๐7U๑7๔7๐7๐ 0๐0๐0๐0๐0e๑0๔0๐0๐ 5๐5๐5๐5๐5˜ ๑5๔5๐5๐ +๐+๐+๐+๐+˜e๑+๔+๐+๐ /๐/๐/๐/๐/ %๑/๔/๐/๐ 0๐0๐0๐0๐0 %๑0๔0๐0๐ =๐=๐=๐=๐=˜u๑=๔=๐=๐ &๐&๐&๐&๐&E๑&๔&๐&๐ :๐:๐:๐:๐:˜5๑:๔:๐:๐ /๐/๐/๐/๐/˜๑/๔/๐/๐F๐F๐F๐F๐F˜%๑F๔F๐F๐F๐Fr