4Bcom/hazelcast/collection/impl/queue/operations/QueueMergeOperationHcom/hazelcast/collection/impl/queue/operations/QueueBackupAwareOperation(com/hazelcast/spi/impl/MutatingOperationQueueMergeOperation.java;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;>; mergingValue>Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;backupCollectionLjava/util/Collection;GLjava/util/Collection; shouldBackupZ()V  thisDLcom/hazelcast/collection/impl/queue/operations/QueueMergeOperation;(Ljava/lang/String;Lcom/hazelcast/spi/merge/SplitBrainMergePolicy;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;)V(Ljava/lang/String;Lcom/hazelcast/spi/merge/SplitBrainMergePolicy;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;>;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;)V(Ljava/lang/String;)V    "  $nameLjava/lang/String;run getContainer6()Lcom/hazelcast/collection/impl/queue/QueueContainer; )* +2com/hazelcast/collection/impl/queue/QueueContainer- getItemQueue()Ljava/util/Deque; /0 .1java/util/Deque3isEmpty()Z 56 47 getCurrentId()J 9: .;merge(Lcom/hazelcast/collection/impl/queue/QueueContainer;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;Lcom/hazelcast/spi/merge/SplitBrainMergePolicy;)Ljava/util/Queue; => ?  Ajava/util/CollectionC D7  F container4Lcom/hazelcast/collection/impl/queue/QueueContainer;currentCollectionIsEmpty currentItemIdJO(Lcom/hazelcast/collection/impl/queue/QueueContainer;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;Lcom/hazelcast/spi/merge/SplitBrainMergePolicy;Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes;>;)Ljava/util/Queue; getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; NO Pcom/hazelcast/spi/NodeEngineRgetSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; TU SV4com/hazelcast/spi/serialization/SerializationServiceXgetManagedContext%()Lcom/hazelcast/core/ManagedContext; Z[ Y\!com/hazelcast/core/ManagedContext^ initialize&(Ljava/lang/Object;)Ljava/lang/Object; `a _bcreateMergingValueOrNull(Lcom/hazelcast/spi/serialization/SerializationService;Ljava/util/Queue;)Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes; de f-com/hazelcast/spi/merge/SplitBrainMergePolicyh`(Lcom/hazelcast/spi/merge/MergingValue;Lcom/hazelcast/spi/merge/MergingValue;)Ljava/lang/Object; =j ik!com/hazelcast/util/CollectionUtilm(Ljava/util/Collection;)Z 5o npclear()Ljava/util/Map; rs .tjava/util/QueuevgetQueueService4()Lcom/hazelcast/collection/impl/queue/QueueService; xy z &' |0com/hazelcast/collection/impl/queue/QueueService~destroyDistributedObject  createNewQueueItems(Lcom/hazelcast/collection/impl/queue/QueueContainer;Ljava/util/Collection;Lcom/hazelcast/spi/serialization/SerializationService;)V getValue()Ljava/lang/Object; equals(Ljava/lang/Object;)Z DserializationService6Lcom/hazelcast/spi/serialization/SerializationService; existingItemsBLjava/util/Queue;Ljava/util/Queue; existingValue newValues*Ljava/util/Collection;(Lcom/hazelcast/spi/serialization/SerializationService;Ljava/util/Queue;)Lcom/hazelcast/spi/merge/SplitBrainMergeTypes$QueueMergeTypes; w70com/hazelcast/spi/impl/merge/MergingValueFactorycreateMergingValue e (Lcom/hazelcast/collection/impl/queue/QueueContainer;Ljava/util/Collection;Lcom/hazelcast/spi/serialization/SerializationService;)Viterator()Ljava/util/Iterator; Djava/util/IteratorhasNext 6 next toData:(Ljava/lang/Object;)Lcom/hazelcast/nio/serialization/Data; Yoffer)(Lcom/hazelcast/nio/serialization/Data;)J .valueLjava/lang/Object;valuesafterRungetLocalQueueStatsImplD(Ljava/lang/String;)Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl; .com/hazelcast/monitor/impl/LocalQueueStatsImplincrementOtherOperations  getBackupOperation()Lcom/hazelcast/spi/Operation;Hcom/hazelcast/collection/impl/queue/operations/QueueMergeBackupOperation+(Ljava/lang/String;Ljava/util/Collection;)V  getId()I writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException "com/hazelcast/nio/ObjectDataOutput writeObject(Ljava/lang/Object;)V out$Lcom/hazelcast/nio/ObjectDataOutput; readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V !com/hazelcast/nio/ObjectDataInput readObject in#Lcom/hazelcast/nio/ObjectDataInput; SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFile!  3* 23 v*+!*,#*-%78 9:*&'   (E*,L+28=+?@B%CDD*E@HI6J1KL=>*QW:],cW]-cW+2:*g:-,lD:q+uW*{*}3*+"+uW*+$W. iYw D BH IJ'L-M7NEPMQRRWTeUjVvWXY[RHI  -k7aES  -kESMdep,+, D _  ,,::+-X "de(f+g4 ,,HI,, ,=*{*} kl 6/*Gp :Y*}*Bưu -,z Z*++*#+*%` *+*+i#*+ %