change maven group

build.gradle

@@ -5,7 +5,7 @@ buildscript {
     }
 }
 
-group 'com.mgabriel'
+group 'ch.streamly'
 
 
 apply plugin: 'java'

src/main/java/ch/streamly/chronicle/flux/ChronicleStore.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux;
+package ch.streamly.chronicle.flux;
 
 import java.io.File;
 import java.util.function.Function;
@@ -6,7 +6,7 @@ import java.util.function.Function;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.mgabriel.chronicle.flux.replay.ReplayFlux;
+import ch.streamly.chronicle.flux.replay.ReplayFlux;
 import net.openhft.chronicle.bytes.BytesIn;
 import net.openhft.chronicle.queue.ExcerptAppender;
 import net.openhft.chronicle.queue.ExcerptTailer;

src/main/java/ch/streamly/chronicle/flux/FluxStore.java

@@ -1,8 +1,8 @@
-package com.mgabriel.chronicle.flux;
+package ch.streamly.chronicle.flux;
 
 import java.util.function.Function;
 
-import com.mgabriel.chronicle.flux.replay.ReplayFlux;
+import ch.streamly.chronicle.flux.replay.ReplayFlux;
 import org.reactivestreams.Publisher;
 import reactor.core.Disposable;
 import reactor.core.publisher.Flux;

src/main/java/ch/streamly/chronicle/flux/replay/ReplayFlux.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import java.time.Duration;
 import java.util.function.Function;

src/main/java/ch/streamly/chronicle/flux/replay/ReplayInLoop.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicBoolean;

src/main/java/ch/streamly/chronicle/flux/replay/ReplayValue.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 /**
  * A value wrapper that indicates if the current value is the first value replayed in the replay loop.

src/main/java/ch/streamly/chronicle/flux/replay/ReplayValueImpl.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import java.util.Objects;
 

src/main/java/ch/streamly/chronicle/flux/replay/ReplayWithOriginalTiming.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import static java.time.Duration.ofMillis;
 

src/main/java/ch/streamly/chronicle/flux/replay/Timed.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 /**
  * Wraps a value with its timestamp.

src/main/java/ch/streamly/chronicle/flux/replay/TimedValue.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import java.util.Objects;
 

src/main/java/ch/streamly/chronicle/flux/replay/ValueToDelay.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 
 class ValueToDelay<T> implements WrappedValue<T> {

src/main/java/ch/streamly/chronicle/flux/replay/WrappedValue.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 interface WrappedValue<T> {
     T value();

src/test/java/ch/streamly/chronicle/flux/ChronicleStoreTest.java

@@ -1,6 +1,6 @@
-package com.mgabriel.chronicle.flux;
+package ch.streamly.chronicle.flux;
 
-import static com.mgabriel.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists;
+import static ch.streamly.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists;
 import static java.time.Duration.ofSeconds;
 
 import java.time.Duration;

src/test/java/ch/streamly/chronicle/flux/DummyObject.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux;
+package ch.streamly.chronicle.flux;
 
 import java.nio.charset.Charset;
 import java.util.Objects;

src/test/java/ch/streamly/chronicle/flux/demo/ChronicleStoreDemo.java

@@ -1,13 +1,13 @@
-package com.mgabriel.chronicle.flux.demo;
+package ch.streamly.chronicle.flux.demo;
 
-import static com.mgabriel.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists;
+import static ch.streamly.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 import java.time.Duration;
 import java.time.Instant;
 
-import com.mgabriel.chronicle.flux.ChronicleStore;
+import ch.streamly.chronicle.flux.ChronicleStore;
-import com.mgabriel.chronicle.flux.DummyObject;
+import ch.streamly.chronicle.flux.DummyObject;
 import reactor.core.Disposable;
 import reactor.core.publisher.Flux;
 

src/test/java/ch/streamly/chronicle/flux/demo/ReactiveBuffer.java

@@ -1,11 +1,11 @@
-package com.mgabriel.chronicle.flux.demo;
+package ch.streamly.chronicle.flux.demo;
 
-import static com.mgabriel.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists;
+import static ch.streamly.chronicle.flux.util.ChronicleStoreCleanup.deleteStoreIfItExists;
 
 import java.time.Duration;
 
-import com.mgabriel.chronicle.flux.ChronicleStore;
+import ch.streamly.chronicle.flux.ChronicleStore;
-import com.mgabriel.chronicle.flux.DummyObject;
+import ch.streamly.chronicle.flux.DummyObject;
 import reactor.core.Disposable;
 import reactor.core.publisher.Flux;
 

src/test/java/ch/streamly/chronicle/flux/demo/ReplayFluxDemo.java

@@ -1,10 +1,10 @@
-package com.mgabriel.chronicle.flux.demo;
+package ch.streamly.chronicle.flux.demo;
 
 import static java.time.Duration.ofSeconds;
 
 import java.time.Instant;
 
-import com.mgabriel.chronicle.flux.replay.ReplayFlux;
+import ch.streamly.chronicle.flux.replay.ReplayFlux;
 import reactor.core.publisher.Flux;
 
 class ReplayFluxDemo {

src/test/java/ch/streamly/chronicle/flux/demo/ReplayLoopDemo.java

@@ -1,11 +1,11 @@
-package com.mgabriel.chronicle.flux.demo;
+package ch.streamly.chronicle.flux.demo;
 
 import static java.time.Duration.ofSeconds;
 
 import java.time.Instant;
 
-import com.mgabriel.chronicle.flux.replay.ReplayInLoop;
+import ch.streamly.chronicle.flux.replay.ReplayValue;
-import com.mgabriel.chronicle.flux.replay.ReplayValue;
+import ch.streamly.chronicle.flux.replay.ReplayInLoop;
 import reactor.core.publisher.Flux;
 
 class ReplayLoopDemo {

src/test/java/ch/streamly/chronicle/flux/demo/ReplayWithOriginalTimingDemo.java

@@ -1,8 +1,8 @@
-package com.mgabriel.chronicle.flux.demo;
+package ch.streamly.chronicle.flux.demo;
 
 import java.time.Instant;
 
-import com.mgabriel.chronicle.flux.replay.ReplayWithOriginalTiming;
+import ch.streamly.chronicle.flux.replay.ReplayWithOriginalTiming;
 import reactor.core.publisher.Flux;
 
 class ReplayWithOriginalTimingDemo {

src/test/java/ch/streamly/chronicle/flux/replay/ReplayFluxTest.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import static java.time.Duration.ofMillis;
 import static java.time.Duration.ofSeconds;
@@ -11,7 +11,7 @@ import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 
-import com.mgabriel.chronicle.flux.DummyObject;
+import ch.streamly.chronicle.flux.DummyObject;
 import reactor.core.Scannable;
 import reactor.core.publisher.Flux;
 import reactor.test.StepVerifier;

src/test/java/ch/streamly/chronicle/flux/replay/ReplayValueImplTest.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import static org.junit.jupiter.api.Assertions.*;
 

src/test/java/ch/streamly/chronicle/flux/replay/TimedValueTest.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.replay;
+package ch.streamly.chronicle.flux.replay;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotEquals;

src/test/java/ch/streamly/chronicle/flux/util/ChronicleStoreCleanup.java

@@ -1,4 +1,4 @@
-package com.mgabriel.chronicle.flux.util;
+package ch.streamly.chronicle.flux.util;
 
 import java.io.File;
 import java.io.IOException;