42com/hazelcast/collection/impl/queue/QueueContainerjava/lang/Object:com/hazelcast/nio/serialization/IdentifiedDataSerializableQueueContainer.javajava/util/Map$Entry java/util/Map EntrytxMapLjava/util/Map;ULjava/util/Map;dataMapGLjava/util/Map;pollWaitNotifyKey8Lcom/hazelcast/collection/impl/queue/QueueWaitNotifyKey;offerWaitNotifyKey itemQueueLjava/util/LinkedList;GLjava/util/LinkedList; backupMapPLjava/util/Map;config"Lcom/hazelcast/config/QueueConfig;store7Lcom/hazelcast/collection/impl/queue/QueueStoreWrapper; nodeEngineLcom/hazelcast/spi/NodeEngine;service2Lcom/hazelcast/collection/impl/queue/QueueService;loggerLcom/hazelcast/logging/ILogger; idGeneratorJnameLjava/lang/String;minAgemaxAgetotalAgetotalAgedCountisEvictionScheduledZ lastIdLoaded()V /0 1java/util/HashMap3 41  6  8 (% < )% @this4Lcom/hazelcast/collection/impl/queue/QueueContainer;(Ljava/lang/String;)V &' E6com/hazelcast/collection/impl/queue/QueueWaitNotifyKeyGpollI'(Ljava/lang/String;Ljava/lang/String;)V /K HL  NofferP  R(Ljava/lang/String;Lcom/hazelcast/config/QueueConfig;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/collection/impl/queue/QueueService;)V /D U setConfigu(Lcom/hazelcast/config/QueueConfig;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/collection/impl/queue/QueueService;)V WX Yinit(Z)V  ]5com/hazelcast/collection/impl/queue/QueueStoreWrapper_ isEnabled()Z ab `c loadAllKeys()Ljava/util/Set; ef `g java/util/Setkiterator()Ljava/util/Iterator; mn lojava/util/IteratorqhasNext sb rtnext()Ljava/lang/Object; vw rxjava/lang/Longz-com/hazelcast/collection/impl/queue/QueueItem| longValue()J ~ {^(Lcom/hazelcast/collection/impl/queue/QueueContainer;JLcom/hazelcast/nio/serialization/Data;)V / } getItemQueue()Ljava/util/Deque; java/util/Deque(Ljava/lang/Object;)Z P java/lang/Mathmax(JJ)J $% item/Lcom/hazelcast/collection/impl/queue/QueueItem;keyLjava/lang/Long;maxIdkeys!Ljava/util/Set;Ljava/util/Set; fromBackupgetStore9()Lcom/hazelcast/collection/impl/queue/QueueStoreWrapper;getName()Ljava/lang/String;txnCheckReserve(J)ZvalueOf(J)Ljava/lang/Long; {get&(Ljava/lang/Object;)Ljava/lang/Object; .com/hazelcast/transaction/TransactionExceptionjava/lang/StringBuilder 1No reserve for itemId: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; (J)Ljava/lang/StringBuilder; toString UitemIdtxnEnsureBackupReserve(JLjava/lang/String;Z)VtxnPollBackupReserve(JLjava/lang/String;)V txnOfferBackupReserve  transactionId pollOperationtxnPollReserveD(JLjava/lang/String;)Lcom/hazelcast/collection/impl/queue/QueueItem;java/lang/Exceptionpeek w remove 2com/hazelcast/collection/impl/txnqueue/TxQueueItem getItemId  getData(()Lcom/hazelcast/nio/serialization/Data; }load2(Lcom/hazelcast/collection/impl/queue/QueueItem;)V %com/hazelcast/core/HazelcastException(Ljava/lang/Throwable;)V / Iw } / setPollOperation7(Z)Lcom/hazelcast/collection/impl/txnqueue/TxQueueItem; setTransactionIdH(Ljava/lang/String;)Lcom/hazelcast/collection/impl/txnqueue/TxQueueItem; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; txItem4Lcom/hazelcast/collection/impl/txnqueue/TxQueueItem;eLjava/lang/Exception;reservedOfferId getBackupMap()Ljava/util/Map;  "# $Poll backup reserve failed, itemId:  is not foundcom/hazelcast/logging/ILoggerwarning  D    txnCommitPoll)(J)Lcom/hazelcast/nio/serialization/Data;txnCommitPollBackup  scheduleEvictionIfEmpty 0 result&Lcom/hazelcast/nio/serialization/Data;2txnCommitPoll operation-> No txn item for itemId: delete(Ljava/lang/Long;)V  `Error during store delete: severe*(Ljava/lang/String;Ljava/lang/Throwable;)V   !txnRollbackPoll(JZ)ZaddTxItemOrdered7(Lcom/hazelcast/collection/impl/txnqueue/TxQueueItem;)V %& 'cancelEvictionIfExists )0 *backupjava/util/List- listIterator()Ljava/util/ListIterator; /0 .1java/util/ListIterator3 4t 4x % 7 }7previous :w 4;add(Ljava/lang/Object;)V => 4? queueItem txQueueItemILjava/util/ListIterator;Ljava/util/ListIterator;txnOfferReserve(Ljava/lang/String;)JnextId G HtxnOfferReserveInternalI(JLjava/lang/String;)Lcom/hazelcast/collection/impl/txnqueue/TxQueueItem; JK LKtxnOfferBackupReserve operation-> Item exists already at txMap for itemId: N D  Po txnCommitOffer+(JLcom/hazelcast/nio/serialization/Data;Z)Z No reserve: VsetData)(Lcom/hazelcast/nio/serialization/Data;)V XY }Z9(Ljava/lang/Long;Lcom/hazelcast/nio/serialization/Data;)V \ `]Exception during store_    adatatxnRollbackOffertxnRollbackOfferBackup e f5txnRollbackOffer operation-> No txn item for itemId: htxnPeekofferId)(Lcom/hazelcast/nio/serialization/Data;)J$com/hazelcast/nio/serialization/DatamgetMemoryLimit()I op `qsize sp t offerBackup*(Lcom/hazelcast/nio/serialization/Data;J)VaddAll'(Ljava/util/Collection;)Ljava/util/Map;(Ljava/util/Collection;)Ljava/util/Map;java/util/Collection{ |tcom/hazelcast/util/MapUtil~ createHashMap(I)Ljava/util/Map;  java/util/ArrayList(I)V /  |o = .isEmpty b storeAll(Ljava/util/Map;)V  ` .(Ljava/util/Collection;)Z x dataList>Ljava/util/Collection;Ljava/util/Collection;maplistALjava/util/List;Ljava/util/List; addAllBackupJ(Ljava/util/Map;)VentrySet f getKey w getValue w entryMLjava/util/Map$Entry;Ljava/util/Map$Entry;1()Lcom/hazelcast/collection/impl/queue/QueueItem;  com/hazelcast/util/ClockcurrentTimeMillis  age3(Lcom/hazelcast/collection/impl/queue/QueueItem;J)V   pollBackup(J)VdrainJ(I)Ljava/util/Map;createLinkedHashMap  mapDrainIterator(ILjava/util/Map;)V  keySet f  deleteAll(Ljava/util/Collection;)V  `iImaxSize maxSizeParamcurrentK(ILjava/util/Map;)V oELjava/util/Iterator;Ljava/util/Iterator;drainFromBackup(Ljava/util/Set;)V$(Ljava/util/Set;)V  clear 0  itemIdSet   com/hazelcast/config/QueueConfig getMaxSize p min(II)I   txMapSize t backupSizeI()Ljava/util/Map;  clearBackup  equals   0 r removeBackupcontainsA(Ljava/util/Collection;)ZdataSet getAsDataList()Ljava/util/List;:()Ljava/util/List;8Ljava/util/List;compareAndRemove((Ljava/util/Collection;Z)Ljava/util/Map;(Ljava/util/Collection;Z)Ljava/util/Map;java/util/LinkedHashMap 1  | mapIterateAndRemove  retainQLjava/util/LinkedHashMap;Ljava/util/LinkedHashMap; containsKey   compareAndRemoveBackup getBulkLoad p `8(Ljava/lang/Long;)Lcom/hazelcast/nio/serialization/Data;  `com/hazelcast/util/SetUtil createHashSet(I)Ljava/util/Set;   l lt .% loadAll y ` putAll " #getDataFromMap % & maxIdToLoadvaluesbulkLoadhasEnoughCapacity(I)Z +, -deltaD()Ljava/util/Deque;  1java/util/LinkedList3 41  6()Ljava/util/Collection; )8 9 / ;java/util/Collections=sort(Ljava/util/List;)V ?@ >A 4peekLast Dw 4EsetId I JlastItem maxItemIdR()Ljava/util/Map; 4t 4o 4  R ! Tcom/hazelcast/spi/NodeEngineV getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; XY WZ%(Lcom/hazelcast/config/QueueConfig;)V /\ ]getQueueStoreConfig)()Lcom/hazelcast/config/QueueStoreConfig; _` agetSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; cd WegetConfigClassLoader()Ljava/lang/ClassLoader; gh Wicreate(Ljava/lang/String;Lcom/hazelcast/config/QueueStoreConfig;Lcom/hazelcast/spi/serialization/SerializationService;Ljava/lang/ClassLoader;)Lcom/hazelcast/collection/impl/queue/QueueStoreWrapper; kl `m storeConfig'Lcom/hazelcast/config/QueueStoreConfig;serializationService6Lcom/hazelcast/spi/serialization/SerializationService; classLoaderLjava/lang/ClassLoader; getCurrentIdgetPollWaitNotifyKey:()Lcom/hazelcast/collection/impl/queue/QueueWaitNotifyKey;getOfferWaitNotifyKey getConfig$()Lcom/hazelcast/config/QueueConfig;getCreationTime { }| +% ~ *%    currentTimeelapsedsetStats3(Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl;)V.com/hazelcast/monitor/impl/LocalQueueStatsImpl setMinAge   setMaxAge   setAveAge  stats0Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl;totalAgedCountValgetEmptyQueueTtl p   ,- getProxyService"()Lcom/hazelcast/spi/ProxyService;  Whz:impl:queueServicecom/hazelcast/spi/ProxyServicedestroyDistributedObject K java/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;  toMillis(J)J  0com/hazelcast/collection/impl/queue/QueueServicescheduleEviction(Ljava/lang/String;J)V   emptyQueueTtlcancelEviction D  isEvictablerollbackTransactiongetTransactionId  java/lang/String isPollOperation b  offerFirst  JLjava/util/Iterator; writeData'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException"com/hazelcast/nio/ObjectDataOutputwriteUTF D writeInt   writeObject >   out$Lcom/hazelcast/nio/ObjectDataOutput;readData&(Lcom/hazelcast/nio/ObjectDataInput;)V!com/hazelcast/nio/ObjectDataInputreadUTF  readInt p  readObject w   jin#Lcom/hazelcast/nio/ObjectDataInput;txSizedestroy getFactoryId;com/hazelcast/collection/impl/queue/QueueDataSerializerHookF_ID  getId SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Exceptions InnerClasses SourceFile!  !"#$%&'(%)%*%+%,-.%C/0g)*2*4Y57*4Y59*:=*>AaDEU!V(b )BC/DJ*2*4Y57*4Y59*:=*>A*+F*HY+JMO*HY+QMS& dDEU!V(e-f;gIhJBCJ&'/Th*+V*,-Zkl m4BC&' ![\mk*^da*^hM,UiB,p:u8y{:}Y*:*W!B*! a&lr>. xyz{|<}L~Xbel>L<&N%VmBCm- V/*^ BC/*F BCr-*7YY++-BC-%%*7 *-ŧ *-ȱ$*%BC%%%'%-O*}:3*7:}Y*ݷ:*^d *:Y*W*7Y-WU[^,}Z >%*,@CU[^`jt>%` BC%'k*}:#*7Y-W*7&*Y  7}267Gj*kBCk%k'Y R *N*-   BC %x*7N-"*Y *^d8*^-ٸ':*Y-ٶ"-ݰ>LO 4Z#* 24>LOQs*Q"xBCx%g#$<*7:*W *(*+ "06:*<BC<%<,-*%&A*.2M,5&,6}N+8-9 ,<W,+@  4(&   !,"3#6%9&@'* AABCAB 4mD  4mCEFT*IA* +MW 34 5 BC' %+*-M: *YOQ*@A B*D*+BC+%+'#RJK{'Y*S-:*7ְJ KLM*'BC'%''TUa*7}:$YYW}Y*-:-[*W*+*W*^d+&*^-^:*`b8}aB_`a8b=cIeOfTg`hgjwlnqops>BC%c,-dR *g>*~   BC %-e6*7}N-"*Yi 4}24 6BC6%%j/w*}:=i*7:}Y*ݷ:*^d *:Y_eh}Z >/46JM_ehjt>/j wBCwk%w'iPlj}Y**IM*^d*^,+^ NY-*^d*^r*u,+[*,W*+,'**n} . '*+4QVae*+ jBCjc\vw@}Y* :*^d*^r*u +[* W )} )/?*@BC@c@% 4xy+}MY+}N+:u_yn:}Y**I:*^d*^r*u [,W-W*^d#,*^,:Y-*-W*+,!  .rAn}] J 6EbizHE>6Mc BC   zy+pM,uf,y N}Y*-{:*^d*^r*u-n[*W rF } 6Saux*6?VyBCyVy8*}L+*^d+*+ MY,+$), }X &  $),-6 - 8BC +IH*L+*^d*^+ MY,*W*+*+#&  }Z 2 &' ( *,#/&-'.01:2B3F4 ' HBCCv*}N- *-}?@BD BC% }=*u *u=N*-*^d#*^-ɧ:Y翸76*}:**-6CF# (  !JOPQS"T(U6WCZFXHYR\W]`^n`v]|bceRH nZ"BC"dW/% "d=`*N6O-y}:*^d *:Y,޹W069% r+ r} . i jkl0n6q9o;pEsYj_uH; ; R`BC`` Vm` Vm/+pM,u,y{N*-ק*9 rxy"z%{.| /BC/ /sp>*ݶ*u BCp4 *7  BCp4 *  BCU@*uN*:u-y}:-޹W**^d(-*^-ɧ:Y**9*-cps r3b >2FMPcpsu42u BC% P*+ BC l:m*M,uY,y}N+-޶A*^d *^-:Y,*-*-ꭧi2@C# r8nr} > (2@CEOU]afi4E ImBCmc cm  cmG*W BC%g+M,uX,ynN6*:u,y}:- 6r nr/. >RUX[`be4>E-HcgBCg gcY*uL*M,u@,y}N*^d-*-:Y+-޹W+?DG%.r+.r} * .?DGIS^a*I .0cBCR R|YN*:ujy}:"*^d*:Y+޹6 -޶W*--;AD1r0|r} 6 ) ; AD F P]oHF ]$-)XBC-  9q+*^d*^+ɧ MY,*M,u.,y}N+- ,*-*!$ Y r0B" # &(!+$)%*.-8.A/K0[1a3i5l6p74% KqBCq89mq89mP*+ :;BC  *^=*u=+*^+[iB*::+W=u3y}7*W!B*^!:*!*9$+*+'[0(rlA&RJKLM0N5O9PDQJSYTnU}VWXZ\]^_aR}%9(%DmJ{)BC* DmJ{)+b0*.i BC+,Z*u`*ݶ@sBC/*2*4Y52*7V*7JY*7:@*7:N-u-y:8@*GaK*2^.} r J%6:CNR^glx|466)NL |9M%BC 66)0k*7b*2P**2O7*2PL+u"+y}M*7,,W*2Q*2*4Y57*7 $r' * 7ILS[f7kBCN%E*9nBC%WXJ*,S*-U*,[*Y+^+b:,f:,j:**Fn^&  "(08IHJBCJJJ !("op0qr8stG6 *Y a]  BCu/* BCvw/*O BCxw/*S BCyz/*ݰ BC@ +}e7 *Y a*Ya**==**AA"%2?*@BC@@%8%r$+*=+*A* A+* m# $BC$ %0a*ݶ<*J*7>*7*S*F*U*F* :&   ,0H[`aBCY)0W**U*F* BCbS**7@ BCDM*7:M,u7,yN+-™,-ř*-W*+Ʊ r9*    "-3:EIL*"'MBCM'>m >mz+*F+*u*M,u,y}N+-+*7*7:M,u,yN-+ڧ#rr*  6=@O q!v"y#*6qzBCzp*+F*HY*FJMO*HY*FQMS+=>)+}:*W*K+>6:Y*iS:+*7ٸW*ٶKƱ5* <F' (),*3+:,E-Q.Z+`0g1p2~34517RE5+~#j=BC3usgA0}1*2 *2Q*7 *7*7*9:;=>@'A0B 1BCp.F BCp-&K BCIG* a* OPBC%