4HEcom/hazelcast/collection/impl/txnqueue/TransactionalQueueProxySupportLcom/hazelcast/spi/TransactionalDistributedObject;Lcom/hazelcast/core/TransactionalQueue;0com/hazelcast/spi/TransactionalDistributedObject%com/hazelcast/core/TransactionalQueue#TransactionalQueueProxySupport.java0com/hazelcast/transaction/impl/Transaction$State *com/hazelcast/transaction/impl/Transaction StatenameLjava/lang/String; partitionIdIconfig"Lcom/hazelcast/config/QueueConfig; offeredQueueLjava/util/LinkedList;GLjava/util/LinkedList; itemIdSetLjava/util/Set;!Ljava/util/Set;(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/collection/impl/queue/QueueService;Ljava/lang/String;Lcom/hazelcast/transaction/impl/Transaction;)Vn(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/spi/RemoteService;Lcom/hazelcast/transaction/impl/Transaction;)V  java/util/LinkedList()V ! "  $java/util/HashSet& '"  )  +com/hazelcast/spi/NodeEngine-getPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService; /0 .1getNameAsPartitionAwareData(()Lcom/hazelcast/nio/serialization/Data; 34 5-com/hazelcast/spi/partition/IPartitionService7getPartitionId)(Lcom/hazelcast/nio/serialization/Data;)I 9: 8;  = getConfig()Lcom/hazelcast/config/Config; ?@ .Acom/hazelcast/config/ConfigCfindQueueConfig6(Ljava/lang/String;)Lcom/hazelcast/config/QueueConfig; EF DG  IthisLLcom/hazelcast/collection/impl/txnqueue/TransactionalQueueProxySupport;GLcom/hazelcast/collection/impl/txnqueue/TransactionalQueueProxySupport; nodeEngineLcom/hazelcast/spi/NodeEngine;service2Lcom/hazelcast/collection/impl/queue/QueueService;tx,Lcom/hazelcast/transaction/impl/Transaction;getName()Ljava/lang/String;getServiceNamehz:impl:queueServiceWsize()Ijava/lang/Throwable[checkTransactionState ]! ^;Ljava/util/concurrent/Future;Ljava/lang/Integer;tLjava/lang/Throwable; operation>Lcom/hazelcast/collection/impl/queue/operations/SizeOperation; RS getState4()Lcom/hazelcast/transaction/impl/Transaction$State; ACTIVE2Lcom/hazelcast/transaction/impl/Transaction$State; equals(Ljava/lang/Object;)Z 7com/hazelcast/transaction/TransactionNotActiveExceptionTransaction is not active! c offerInternal*(Lcom/hazelcast/nio/serialization/Data;J)ZJcom/hazelcast/collection/impl/txnqueue/operations/TxnReserveOfferOperationgetTxnId U )(Ljava/lang/String;JILjava/lang/String;)V   getOwnerUuid U  setCallerUuid1(Ljava/lang/String;)Lcom/hazelcast/spi/Operation; java/lang/Long java/util/Setadd .com/hazelcast/transaction/TransactionExceptionjava/lang/StringBuilder "Duplicate itemId: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString U c-com/hazelcast/collection/impl/queue/QueueItem longValue()J ^(Lcom/hazelcast/collection/impl/queue/QueueContainer;JLcom/hazelcast/nio/serialization/Data;)V  offer Ccom/hazelcast/collection/impl/txnqueue/operations/TxnOfferOperation<(Ljava/lang/String;JLcom/hazelcast/nio/serialization/Data;)V   putToRecordL(Lcom/hazelcast/collection/impl/txnqueue/operations/BaseTxnQueueOperation;)V txnOfferOperationELcom/hazelcast/collection/impl/txnqueue/operations/TxnOfferOperation;/Ljava/util/concurrent/Future;itemIdLjava/lang/Long;data&Lcom/hazelcast/nio/serialization/Data;timeoutJLLcom/hazelcast/collection/impl/txnqueue/operations/TxnReserveOfferOperation; pollInternal)(J)Lcom/hazelcast/nio/serialization/Data;peek l  getItemId Icom/hazelcast/collection/impl/txnqueue/operations/TxnReservePollOperation)(Ljava/lang/String;JJLjava/lang/String;)V  poll l removeFromRecord(J)V valueOf(J)Ljava/lang/Long; remove getData 4 (J)Ljava/lang/StringBuilder;  Bcom/hazelcast/collection/impl/txnqueue/operations/TxnPollOperation(Ljava/lang/String;J)V  txnPollOperationDLcom/hazelcast/collection/impl/txnqueue/operations/TxnPollOperation;NLjava/util/concurrent/Future;item/Lcom/hazelcast/collection/impl/queue/QueueItem; reservedOfferKLcom/hazelcast/collection/impl/txnqueue/operations/TxnReservePollOperation; peekInternalBcom/hazelcast/collection/impl/txnqueue/operations/TxnPeekOperation DLcom/hazelcast/collection/impl/txnqueue/operations/TxnPeekOperation;I(Ljava/lang/Object;)Lcom/hazelcast/transaction/impl/TransactionLogRecord; k @com/hazelcast/collection/impl/txnqueue/QueueTransactionLogRecord((Ljava/lang/String;Ljava/lang/String;I)V  8(Lcom/hazelcast/transaction/impl/TransactionLogRecord;)V   addOperationG(Lcom/hazelcast/collection/impl/txncollection/CollectionTxnOperation;)V  ! "ILcom/hazelcast/collection/impl/txnqueue/operations/BaseTxnQueueOperation; logRecordBLcom/hazelcast/collection/impl/txnqueue/QueueTransactionLogRecord;removeOperation(J)I '( )(Ljava/lang/Object;)V + ,g(Lcom/hazelcast/spi/Operation;)Lcom/hazelcast/spi/InternalCompletableFuture; getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; /0 1getOperationService&()Lcom/hazelcast/spi/OperationService; 34 .5"com/hazelcast/spi/OperationService7invokeOnPartition_(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InternalCompletableFuture; 9: 8;Lcom/hazelcast/spi/Operation;operationService$Lcom/hazelcast/spi/OperationService; SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable InnerClasses SourceFile!@@ AE*+,* Y#%*'Y(**-,*+2*6<>*+B-HJB?:<@#A6BDCC4EKMENOEPQEERSD EKLTUAA*,BGC KMD KLVUA?XBLC KMD KLYZA3*_aY*,dL*+hM,npN-s*%u`M,{,-\E-a\BQRTU V-W.XC4|~ Y.3KM#D|}3KL]!Aj* YEB]^`C KMD KLAY*, *%u*:*W*h:n:^**YY*%Y+ɶWY*,+:* :{-\Epj0B\BBp qr-t5uAvFwTxpz{|}CR5l|~A`KMD5l|KLA *%N- -7Y*,*:*W*h:n:-6-锚)*%W*-**-W-**"YYY*,: *  :{C\\E+Cyj2B\BV 4CKW\mu}C\   K|~W  KM  4DK| KLAr v*%N- -7Y*,*:*h:n:--锚- :{4bl\chl\E*CIjB\B6 4<HM^cilntCR<-|~H!  nvKMv k [4BD<-| vKLA>**,M,&Y**,*>M*,,+#E8B.8=C >KM>$-%&D >KLA+**,N-*6**,-E *B*C*+KM+%&YD +KLefAl*26M,X+*><B  C KM= >?D KL@.F  @@G