ddlmZddlZddlmZmZddlmZddlm Z ddl m Z GddeZ ejZeje j Gd d eZy) )futuresN) NamedTupleCallable)Message) PubsubMessage)AcknowledgeStatusc.eZdZUeed<eed<defdZy)AckId generationoffsetreturnc^t|jdzt|jzS)N,)strr r selfs Olib/third_party/google/cloud/pubsublite/cloudpubsub/internal/wrapped_message.pyencodez AckId.encodes$4??#c)C ,<<<N)__name__ __module__ __qualname__int__annotations__rrrrr r sO K==rr ceZdZUeed<eeegdfed<dejjdedeeegdfffd Z dZ dd Z d Z dd ZdZdefdZded d fdZxZS)WrappedMessage_idN _ack_handlerpback_id ack_handlercbt|||jdd||_||_y)N)super__init__rrr)rr r!r" __class__s rr&zWrappedMessage.__init__s- V]]_a6'rc<|j|jdyNTrrrs rackzWrappedMessage.ack$s $((D)rr futures.FuturecF|j|jdtSr)rr_SUCCESS_FUTURErs rack_with_responsez WrappedMessage.ack_with_response's $((D)rc<|j|jdyNFr*rs rnackzWrappedMessage.nack+s $((E*rcF|j|jdtSr2r.rs rnack_with_responsez!WrappedMessage.nack_with_response.s $((E*rc.tjdy)NznLikely incorrect call to drop() on Pub/Sub Lite message. Pub/Sub Lite does not support redelivery in this way.loggingwarningrs rdropzWrappedMessage.drop2s | rsecondsc.tjdy)Nz}Likely incorrect call to modify_ack_deadline() on Pub/Sub Lite message. Pub/Sub Lite does not support redelivery in this way.r7rr;s rmodify_ack_deadlinez"WrappedMessage.modify_ack_deadline7s L rc8tjdtS)NzLikely incorrect call to modify_ack_deadline_with_response() on Pub/Sub Lite message. Pub/Sub Lite does not support redelivery in this way.)r8r9r/r=s r!modify_ack_deadline_with_responsez0WrappedMessage.modify_ack_deadline_with_response<s Z r)r r,)rrrr rrboolrmetar r&r+r0r3r5r:rr>r@ __classcell__)r's@rrrs JE4=$.//(    ! !((udmT12 (*+  3 AQrr) concurrentrr8typingrr)google.cloud.pubsub_v1.subscriber.messagergoogle.pubsub_v1r,google.cloud.pubsub_v1.subscriber.exceptionsrr Futurer/ set_resultSUCCESSrrrrrLsT'=*J=J=!'..",445*W*r