40com/hazelcast/collection/impl/queue/QueueServiceLjava/lang/Object;Lcom/hazelcast/spi/ManagedService;Lcom/hazelcast/spi/MigrationAwareService;Lcom/hazelcast/spi/TransactionalService;Lcom/hazelcast/spi/RemoteService;Lcom/hazelcast/spi/EventPublishingService;Lcom/hazelcast/spi/StatisticsAwareService;Lcom/hazelcast/spi/QuorumAwareService;Lcom/hazelcast/spi/SplitBrainHandlerService;java/lang/Object com/hazelcast/spi/ManagedService'com/hazelcast/spi/MigrationAwareService&com/hazelcast/spi/TransactionalService com/hazelcast/spi/RemoteService (com/hazelcast/spi/EventPublishingService(com/hazelcast/spi/StatisticsAwareService$com/hazelcast/spi/QuorumAwareService*com/hazelcast/spi/SplitBrainHandlerServiceQueueService.java7com/hazelcast/collection/impl/queue/QueueService$MergerMerger2com/hazelcast/collection/impl/queue/QueueService$22com/hazelcast/collection/impl/queue/QueueService$1java/util/Map$Entry java/util/Map Entry SERVICE_NAMELjava/lang/String;hz:impl:queueService% NULL_OBJECTLjava/lang/Object; containerMap$Ljava/util/concurrent/ConcurrentMap;lLjava/util/concurrent/ConcurrentMap;statsMaphLjava/util/concurrent/ConcurrentMap;"localQueueStatsConstructorFunction(Lcom/hazelcast/util/ConstructorFunction;lLcom/hazelcast/util/ConstructorFunction;quorumConfigCacheJLjava/util/concurrent/ConcurrentMap;quorumConfigCacheMutexFactory(Lcom/hazelcast/util/ContextMutexFactory;quorumConfigConstructorNLcom/hazelcast/util/ConstructorFunction; nodeEngineLcom/hazelcast/spi/NodeEngine;serializationService6Lcom/hazelcast/spi/serialization/SerializationService;partitionService/Lcom/hazelcast/spi/partition/IPartitionService;loggerLcom/hazelcast/logging/ILogger;queueEvictionScheduler1Lcom/hazelcast/util/scheduler/EntryTaskScheduler;ULcom/hazelcast/util/scheduler/EntryTaskScheduler;!(Lcom/hazelcast/spi/NodeEngine;)V()V BD E&java/util/concurrent/ConcurrentHashMapG HE )* J(I)V BL HM ,* O5(Lcom/hazelcast/collection/impl/queue/QueueService;)V BQ R ./ T 1* V&com/hazelcast/util/ContextMutexFactoryX YE 34 [ R 5/ ^ 78 `com/hazelcast/spi/NodeEnginebgetSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; de cf 9: hgetPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService; jk cl ;< n getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; pq cr => tgetExecutionService&()Lcom/hazelcast/spi/ExecutionService; vw cx"com/hazelcast/spi/ExecutionServicezgetGlobalTaskScheduler#()Lcom/hazelcast/spi/TaskScheduler; |} {~:com/hazelcast/collection/impl/queue/QueueEvictionProcessor BC )com/hazelcast/util/scheduler/ScheduleTypePOSTPONE+Lcom/hazelcast/util/scheduler/ScheduleType; 6com/hazelcast/util/scheduler/EntryTaskSchedulerFactory newScheduler(Lcom/hazelcast/spi/TaskScheduler;Lcom/hazelcast/util/scheduler/ScheduledEntryProcessor;Lcom/hazelcast/util/scheduler/ScheduleType;)Lcom/hazelcast/util/scheduler/EntryTaskScheduler; ?@ this2Lcom/hazelcast/collection/impl/queue/QueueService;globalScheduler!Lcom/hazelcast/spi/TaskScheduler;entryProcessor;Ljava/util/Map$Entry;event-Lcom/hazelcast/spi/PartitionReplicationEvent; migrationDataWLjava/util/Map;Ljava/util/Map;commitMigration)com/hazelcast/spi/PartitionMigrationEventAgetMigrationEndpoint1()Lcom/hazelcast/spi/partition/MigrationEndpoint; CD BE-com/hazelcast/spi/partition/MigrationEndpointGSOURCE/Lcom/hazelcast/spi/partition/MigrationEndpoint; IJ HK B getNewReplicaIndex N BO&clearQueuesHavingLesserBackupCountThan(II)V QR SrollbackMigration DESTINATION VJ HWgetCurrentReplicaIndex Y BZdestroy \D ]remove _D `containerPartitionIdthresholdReplicaIndexsLjava/util/Iterator;>;Ljava/util/Iterator; dispatchEventT(Lcom/hazelcast/collection/impl/queue/QueueEvent;Lcom/hazelcast/core/ItemListener;)VgetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; hi cj.com/hazelcast/collection/impl/queue/QueueEventlcallerLcom/hazelcast/nio/Address; no mp-com/hazelcast/internal/cluster/ClusterServicer getMember@(Lcom/hazelcast/nio/Address;)Lcom/hazelcast/instance/MemberImpl; tu sv7com/hazelcast/collection/impl/common/DataAwareItemEventx $ mz eventType"Lcom/hazelcast/core/ItemEventType; |} m~data&Lcom/hazelcast/nio/serialization/Data;  m(Ljava/lang/String;Lcom/hazelcast/core/ItemEventType;Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/core/Member;Lcom/hazelcast/spi/serialization/SerializationService;)V B ycom/hazelcast/logging/ILogger isInfoEnabled  java/lang/StringBuilder EDropping event append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  -(Ljava/lang/Object;)Ljava/lang/StringBuilder;   from unknown address:toString()Ljava/lang/String;  info  !com/hazelcast/instance/MemberImplcom/hazelcast/core/ItemEvent com/hazelcast/core/ItemEventTypeADDED } equals  com/hazelcast/core/ItemListener itemAdded!(Lcom/hazelcast/core/ItemEvent;)V   itemRemoved  getLocalQueueStatsImplD(Ljava/lang/String;)Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl;  .com/hazelcast/monitor/impl/LocalQueueStatsImplincrementReceivedEvents D 0Lcom/hazelcast/collection/impl/queue/QueueEvent;listener!Lcom/hazelcast/core/ItemListener;member#Lcom/hazelcast/instance/MemberImpl; itemEventLcom/hazelcast/core/ItemEvent;createDistributedObjectH(Ljava/lang/String;)Lcom/hazelcast/collection/impl/queue/QueueProxyImpl; getSplitBrainMergePolicyProvider9()Lcom/hazelcast/spi/merge/SplitBrainMergePolicyProvider;  c-com/hazelcast/internal/config/ConfigValidatorcheckQueueConfig\(Lcom/hazelcast/config/QueueConfig;Lcom/hazelcast/spi/merge/SplitBrainMergePolicyProvider;)V  2com/hazelcast/collection/impl/queue/QueueProxyImpl(Ljava/lang/String;Lcom/hazelcast/collection/impl/queue/QueueService;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/config/QueueConfig;)V B objectId queueConfig"Lcom/hazelcast/config/QueueConfig;destroyDistributedObject _ getEventService"()Lcom/hazelcast/spi/EventService;  ccom/hazelcast/spi/EventServicederegisterAllListeners'(Ljava/lang/String;Ljava/lang/String;)V  addItemListenerI(Ljava/lang/String;Lcom/hazelcast/core/ItemListener;ZZ)Ljava/lang/String;4com/hazelcast/collection/impl/queue/QueueEventFilter B registerLocalListener|(Ljava/lang/String;Ljava/lang/String;Lcom/hazelcast/spi/EventFilter;Ljava/lang/Object;)Lcom/hazelcast/spi/EventRegistration;  registerListener  #com/hazelcast/spi/EventRegistrationgetId   registration%Lcom/hazelcast/spi/EventRegistration; includeValueisLocal eventService Lcom/hazelcast/spi/EventService;filter6Lcom/hazelcast/collection/impl/queue/QueueEventFilter;removeItemListener'(Ljava/lang/String;Ljava/lang/String;)ZderegisterListener9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Object;)Z  registrationId getNodeEngine ()Lcom/hazelcast/spi/NodeEngine;createLocalQueueStats<(Ljava/lang/String;I)Lcom/hazelcast/monitor/LocalQueueStats;setOwnedItemCount  L  setBackupItemCount L getThisAddress()Lcom/hazelcast/nio/Address;  s getPartition,(IZ)Lcom/hazelcast/spi/partition/IPartition;  &com/hazelcast/spi/partition/IPartitiongetOwnerOrNull  com/hazelcast/nio/Address  size " # backupSize % &setStats3(Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl;)V () *stats0Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl; thisAddress partition(Lcom/hazelcast/spi/partition/IPartition;owner;(Ljava/lang/String;)Lcom/hazelcast/monitor/LocalQueueStats;(Ljava/lang/String;)I 3 4   6"com/hazelcast/util/ConcurrencyUtil8getOrPutIfAbsentr(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object; :; 9<createTransactionalObject(Ljava/lang/String;Lcom/hazelcast/transaction/impl/Transaction;)Lcom/hazelcast/collection/impl/txnqueue/TransactionalQueueProxy;>com/hazelcast/collection/impl/txnqueue/TransactionalQueueProxy@(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/collection/impl/queue/QueueService;Ljava/lang/String;Lcom/hazelcast/transaction/impl/Transaction;)V BB AC transaction,Lcom/hazelcast/transaction/impl/Transaction;rollbackTransactionkeySet H IgetOperationService&()Lcom/hazelcast/spi/OperationService; KL cM"com/hazelcast/spi/OperationServiceOScom/hazelcast/collection/impl/txnqueue/operations/QueueTransactionRollbackOperationQ B RSsetPartitionId (I)Lcom/hazelcast/spi/Operation; UV RWcom/hazelcast/spi/OperationY setService1(Ljava/lang/Object;)Lcom/hazelcast/spi/Operation; [\ Z] setNodeEngine=(Lcom/hazelcast/spi/NodeEngine;)Lcom/hazelcast/spi/Operation; _` ZainvokeOnPartitionL(Lcom/hazelcast/spi/Operation;)Lcom/hazelcast/spi/InternalCompletableFuture; cd Pe operationLcom/hazelcast/spi/Operation; transactionId queueNames#Ljava/util/Set;Ljava/util/Set;operationService$Lcom/hazelcast/spi/OperationService;getStats()Ljava/util/Map;L()Ljava/util/Map; #com/hazelcast/util/MapUtils createHashMap(I)Ljava/util/Map; uv tw  2 y queueStat'Lcom/hazelcast/monitor/LocalQueueStats; queueStatsJLjava/util/Map; getQuorumNamegetOrPutSynchronized(Ljava/util/concurrent/ConcurrentMap;Ljava/lang/Object;Lcom/hazelcast/util/ContextMutexFactory;Lcom/hazelcast/util/ConstructorFunction;)Ljava/lang/Object;  9 '(  quorumNameprepareMergeRunnable()Ljava/lang/Runnable;;com/hazelcast/collection/impl/queue/QueueContainerCollectorE(Lcom/hazelcast/spi/NodeEngine;Ljava/util/concurrent/ConcurrentMap;)V B run D r(Lcom/hazelcast/collection/impl/queue/QueueService;Lcom/hazelcast/collection/impl/queue/QueueContainerCollector;)V B  collector=Lcom/hazelcast/collection/impl/queue/QueueContainerCollector;INSTANCE=Lcom/hazelcast/partition/strategy/StringPartitioningStrategy;  4com/hazelcast/spi/serialization/SerializationServicetoDatac(Ljava/lang/Object;Lcom/hazelcast/core/PartitioningStrategy;)Lcom/hazelcast/nio/serialization/Data;  )(Lcom/hazelcast/nio/serialization/Data;)I  keyDatao(Ljava/lang/String;Lcom/hazelcast/transaction/impl/Transaction;)Lcom/hazelcast/transaction/TransactionalObject; >? :(Ljava/lang/String;)Lcom/hazelcast/core/DistributedObject;  '(Ljava/lang/Object;Ljava/lang/Object;)V fg  access$000R(Lcom/hazelcast/collection/impl/queue/QueueService;)Lcom/hazelcast/spi/NodeEngine;x0 access$100 access$200j(Lcom/hazelcast/collection/impl/queue/QueueService;)Lcom/hazelcast/spi/serialization/SerializationService; ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile!  #$&'()*+,*-./01*2345/6789:;<=>?@A$BC*F*HYIK*HYNP*Y*SU*HYIW*YYZ\*Y*]_*+a*+gi*+mo*+su+yMY+N*,->|_ac)k4l?mK}P~Zdp|*78| P* +W   $D *+W   $? 78D8 *K    =* \*K+N--Y+*a+*a*N*K+-: N--*a-5* /?DJOZ4\\$\N?O *K+,W    $ ? *K+ $5WYM*KN-\-:  :*o6:+!$)+,,-W,02Y,+!+,5!^ . +7GSkvyH7?$G/67S#+K8:;<=?+K89=>@\+FL*+M+PT ;U\+FX*+M+[T ;QRgs*KN-]-:  ::*o6$)^-a2D  6 #/;KQTdiorR#L8:/@$;4K$b7ss67sc7de#L89ddfg#*ak+qwNyY+{++-*i:-;*u.*uY+q+, ,*+{h. -1=hiv4;-hp**a+M,*aѻY+**a,ְ **$3*K+M,,^*a&+*W+W   '2 33$%C*a:Y:&+,:&+,:, ,; \ )CC$CCC 8.;a*aN-&+, $ %*$$  /*a)   >x*+N--*K+:-*ak:*o::!-$ -'-+-&;  >78 9:;$<&?6@CBLCVDbEgFpHvIRxx$x67r,-Y6B.oC5/0L,1o 2? *+*+57U $D*P+*U=Y$>?MAY*a*+,D^ $EFG"k*KJM*aNN,:G :*o6RY+TX*^*ab:-fWPM. c de2fBgNhRiYj^kgljmHB%67^ gh25$kki$ ajlWmn  ajkopR*KrxL*KM,.,N-  :*z:+-W+!3q r/s:tBuMvPw4:$B {|/8:R E}?/89 E}~qu!*W+*\*_M,,  C  |~ !!$(ZY*a*KL+Y*+3[*i+M*o,  $ A>1*+,V A0*+V Af7 *+m,V  /*aW W/*iW D# YF]"!"