4=com/hazelcast/ringbuffer/impl/operations/ReplicationOperationcom/hazelcast/spi/Operation:com/hazelcast/nio/serialization/IdentifiedDataSerializable.com/hazelcast/nio/serialization/impl/VersionedReplicationOperation.javajava/util/Map$Entry  java/util/Map Entry migrationDataLjava/util/Map;gLjava/util/Map;()V  this?Lcom/hazelcast/ringbuffer/impl/operations/ReplicationOperation;(Ljava/util/Map;II)Vl(Ljava/util/Map;II)VsetPartitionId (I)Lcom/hazelcast/spi/Operation;  setReplicaIndex    ! partitionIdI replicaIndexrun getService()Ljava/lang/Object; '( )/com/hazelcast/ringbuffer/impl/RingbufferService+entrySet()Ljava/util/Set; -. / java/util/Set1iterator()Ljava/util/Iterator; 34 25java/util/Iterator7hasNext()Z 9: 8;next =( 8>getKey @( A!com/hazelcast/spi/ObjectNamespaceCgetValue E( F1com/hazelcast/ringbuffer/impl/RingbufferContainerHgetPartitionId()I JK LgetRingbufferConfig}(Lcom/hazelcast/ringbuffer/impl/RingbufferService;Lcom/hazelcast/spi/ObjectNamespace;)Lcom/hazelcast/config/RingbufferConfig; NO P addRingbuffer^(ILcom/hazelcast/ringbuffer/impl/RingbufferContainer;Lcom/hazelcast/config/RingbufferConfig;)V RS ,Tns#Lcom/hazelcast/spi/ObjectNamespace; ringbuffer3Lcom/hazelcast/ringbuffer/impl/RingbufferContainer;entrymLjava/util/Map$Entry;Ljava/util/Map$Entry;service1Lcom/hazelcast/ringbuffer/impl/RingbufferService;getServiceName()Ljava/lang/String; _` Dahz:impl:ringbufferServicecjava/lang/Stringeequals(Ljava/lang/Object;)Z gh fi getObjectName k` Dl;(Ljava/lang/String;)Lcom/hazelcast/config/RingbufferConfig; Nn ,ohz:impl:mapServiceq getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; st ucom/hazelcast/spi/NodeEnginew&(Ljava/lang/String;)Ljava/lang/Object; 'y xz!com/hazelcast/map/impl/MapService|getMapServiceContext,()Lcom/hazelcast/map/impl/MapServiceContext; ~ }(com/hazelcast/map/impl/MapServiceContextgetEventJournal2()Lcom/hazelcast/map/impl/journal/MapEventJournal; .com/hazelcast/map/impl/journal/MapEventJournalgetEventJournalConfigN(Lcom/hazelcast/spi/ObjectNamespace;)Lcom/hazelcast/config/EventJournalConfig; toRingbufferConfigu(Lcom/hazelcast/config/EventJournalConfig;Lcom/hazelcast/spi/ObjectNamespace;)Lcom/hazelcast/config/RingbufferConfig; hz:impl:cacheService%com/hazelcast/cache/impl/CacheService6()Lcom/hazelcast/cache/impl/journal/CacheEventJournal; 2com/hazelcast/cache/impl/journal/CacheEventJournal "java/lang/IllegalArgumentExceptionjava/lang/StringBuilder $Unsupported ringbuffer service name append-(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ` (Ljava/lang/String;)V   mapService#Lcom/hazelcast/map/impl/MapService;journal0Lcom/hazelcast/map/impl/journal/MapEventJournal; journalConfig)Lcom/hazelcast/config/EventJournalConfig; cacheService'Lcom/hazelcast/cache/impl/CacheService;4Lcom/hazelcast/cache/impl/journal/CacheEventJournal; serviceNameLjava/lang/String; getFactoryId:com/hazelcast/ringbuffer/impl/RingbufferDataSerializerHookF_ID $ getId writeInternal'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOExceptionsize K "com/hazelcast/nio/ObjectDataOutputwriteInt(I)V  writeObject(Ljava/lang/Object;)V  writeData I containerout$Lcom/hazelcast/nio/ObjectDataOutput; readInternal&(Lcom/hazelcast/nio/ObjectDataInput;)V!com/hazelcast/nio/ObjectDataInputreadInt K com/hazelcast/util/MapUtil createHashMap(I)Ljava/util/Map;  readObject ( '(Lcom/hazelcast/spi/ObjectNamespace;I)V  IreadData Iput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;  namespaceiin#Lcom/hazelcast/nio/ObjectDataInput;mapSize SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFile! 3* 01 z** W*+"4567*#$%$ &U**,L*"06M,<7,? N-BD:-GI:+*M*+QUƱ,8<;<*=5>@?Q@TA45VW@XY*'Z\UM]^ *'Z[NOm,bNd-j+,mpr-j4*vr{}::,:,-j/*v{::,:,YY- f94:STUV$W4X@YJZU[^\n]u^_af 4!@J nu ]^VW_`-dg K.l K,q Y+*"*"06M,<4,? N-BD:+-GI:+ӧɱ 89"vw1x<yDzO{U|X}4<VWOY1$Z\YY 1$Z[K+=*">7+D:IY*M:+*"Wʱ 8& !06DJ>!#W0Y9$KKD$