4>com/hazelcast/collection/impl/queue/operations/AddAllOperationHcom/hazelcast/collection/impl/queue/operations/QueueBackupAwareOperationcom/hazelcast/spi/Notifier(com/hazelcast/spi/impl/MutatingOperationAddAllOperation.javadataListLjava/util/Collection;>Ljava/util/Collection;dataMapLjava/util/Map;GLjava/util/Map;()V  this@Lcom/hazelcast/collection/impl/queue/operations/AddAllOperation;+(Ljava/lang/String;Ljava/util/Collection;)VS(Ljava/lang/String;Ljava/util/Collection;)V(Ljava/lang/String;)V   nameLjava/lang/String;run getContainer6()Lcom/hazelcast/collection/impl/queue/QueueContainer; ! "2com/hazelcast/collection/impl/queue/QueueContainer$hasEnoughCapacity()Z &' %(addAll'(Ljava/util/Collection;)Ljava/util/Map; *+ %,  .java/lang/Boolean0valueOf(Z)Ljava/lang/Boolean; 23 14responseLjava/lang/Object; 67 8queueContainer4Lcom/hazelcast/collection/impl/queue/QueueContainer;afterRunjava/lang/Exception=getQueueService4()Lcom/hazelcast/collection/impl/queue/QueueService; ?@ A  C0com/hazelcast/collection/impl/queue/QueueServiceEgetLocalQueueStatsImplD(Ljava/lang/String;)Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl; GH FI.com/hazelcast/monitor/impl/LocalQueueStatsImplKincrementOtherOperations M LNTRUELjava/lang/Boolean; PQ 1Requals(Ljava/lang/Object;)Z TU 1Vjava/util/CollectionXiterator()Ljava/util/Iterator; Z[ Y\java/util/Iterator^hasNext `' _anext()Ljava/lang/Object; cd _e$com/hazelcast/nio/serialization/Datag com/hazelcast/core/ItemEventTypeiADDED"Lcom/hazelcast/core/ItemEventType; kl jm publishEventK(Lcom/hazelcast/core/ItemEventType;Lcom/hazelcast/nio/serialization/Data;)V op qdata&Lcom/hazelcast/nio/serialization/Data;stats0Lcom/hazelcast/monitor/impl/LocalQueueStatsImpl; shouldBackupgetBackupOperation()Lcom/hazelcast/spi/Operation;Dcom/hazelcast/collection/impl/queue/operations/AddAllBackupOperationz$(Ljava/lang/String;Ljava/util/Map;)V | {} shouldNotifygetNotifiedKey#()Lcom/hazelcast/spi/WaitNotifyKey;getPollWaitNotifyKey:()Lcom/hazelcast/collection/impl/queue/QueueWaitNotifyKey; %getId()I writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException size Y"com/hazelcast/nio/ObjectDataOutputwriteInt(I)V  writeData)(Lcom/hazelcast/nio/serialization/Data;)V out$Lcom/hazelcast/nio/ObjectDataOutput; readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V !com/hazelcast/nio/ObjectDataInputreadInt java/util/ArrayList  readData(()Lcom/hazelcast/nio/serialization/Data; add U YiIin#Lcom/hazelcast/nio/ObjectDataInput; SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions SourceFile!    3* ,- c *+*,01 2      ,*#L+)*+*-/*59 *59 #%67 89#;+=,':;<F*B*DJL+OS*9W+*]M,b,fhN*n-r'L_A BCD:EBFEH :stF :uv>w'5 S*9WL  xy:{Y*D*/~Q '5 S*9WV  2*#[ -` <*++**]M,b,fhN+- _efg1h8i;j 1st<<6*++=*Y>*+W no pqr/q5t*66 *