-> net.infumia (#5)

* move to net.infumia.

* move.

* Update TargetImpl.java

README.md

@@ -1,6 +1,6 @@
 # pubsub
-![Sonatype Nexus (Releases)](https://img.shields.io/nexus/r/tr.com.infumia/pubsub?label=maven-central&server=https%3A%2F%2Foss.sonatype.org%2F)
-![Sonatype Nexus (Snapshots)](https://img.shields.io/nexus/s/tr.com.infumia/pubsub?label=maven-central&server=https%3A%2F%2Foss.sonatype.org)
+![Sonatype Nexus (Releases)](https://img.shields.io/nexus/r/net.infumia/pubsub?label=maven-central&server=https%3A%2F%2Foss.sonatype.org%2F)
+![Sonatype Nexus (Snapshots)](https://img.shields.io/nexus/s/net.infumia/pubsub?label=maven-central&server=https%3A%2F%2Foss.sonatype.org)
 ## How to Use (Developers)
 ### Gradle
 ```groovy
@@ -10,21 +10,21 @@ repositories {
 
 dependencies {
     // Base module
-    implementation "tr.com.infumia:pubsub:VERSION"
+    implementation "net.infumia:pubsub:VERSION"
     // Required, https://mvnrepository.com/artifact/com.github.ben-manes.caffeine/caffeine/
     implementation "com.github.ben-manes.caffeine:caffeine:2.9.3" // for java-8+
     implementation "com.github.ben-manes.caffeine:caffeine:3.1.8" // for java-11+
 
     // Pub/Sub using Redis (Optional)
-    implementation "tr.com.infumia:pubsub-redis:VERSION"
+    implementation "net.infumia:pubsub-redis:VERSION"
     // Required, https://mvnrepository.com/artifact/io.lettuce/lettuce-core/
     implementation "io.lettuce:lettuce-core:6.3.2.RELEASE"
 
     // Kotlin extensions (Optional)
-    implementation "tr.com.infumia:pubsub-kotlin:VERSION"
+    implementation "net.infumia:pubsub-kotlin:VERSION"
 
     // Kotlin protobuf serializer (Optional)
-    implementation "tr.com.infumia:pubsub-kotlin-protobuf:VERSION"
+    implementation "net.infumia:pubsub-kotlin-protobuf:VERSION"
     // Required, https://mvnrepository.com/artifact/org.jetbrains.kotlin/kotlin-reflect/
     implementation "org.jetbrains.kotlin:kotlin-reflect:2.0.0"
     // Required, https://mvnrepository.com/artifact/org.jetbrains.kotlinx/kotlinx-serialization-core/

common/build.gradle.kts

@@ -1,5 +1,5 @@
 plugins {
-    id("tr.com.infumia.pubsub.build.publishing")
+    id("net.infumia.pubsub.build.publishing")
 }
 
 dependencies {

common/src/main/java/tr/com/infumia/pubsub/AwaitingResponder.java → common/src/main/java/net/infumia/pubsub/AwaitingResponder.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.time.Duration;
 import java.util.concurrent.CompletableFuture;

common/src/main/java/tr/com/infumia/pubsub/Broker.java → common/src/main/java/net/infumia/pubsub/Broker.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.time.Duration;
 import java.util.Arrays;

common/src/main/java/tr/com/infumia/pubsub/BrokerStringAbstract.java → common/src/main/java/net/infumia/pubsub/BrokerStringAbstract.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import com.github.benmanes.caffeine.cache.Cache;
 import com.github.benmanes.caffeine.cache.Caffeine;

common/src/main/java/tr/com/infumia/pubsub/Codec.java → common/src/main/java/net/infumia/pubsub/Codec.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 /**
  * The interface for encoding and decoding objects of type {@link T} to and from byte arrays.

common/src/main/java/tr/com/infumia/pubsub/CodecProvider.java → common/src/main/java/net/infumia/pubsub/CodecProvider.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 /**
  * The interface for providing {@link Codec} instances based on the class type.

common/src/main/java/tr/com/infumia/pubsub/CodecProviderCached.java → common/src/main/java/net/infumia/pubsub/CodecProviderCached.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.HashMap;
 import java.util.Map;

common/src/main/java/tr/com/infumia/pubsub/Envelope.java → common/src/main/java/net/infumia/pubsub/Envelope.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.Arrays;
 import java.util.Objects;

common/src/main/java/tr/com/infumia/pubsub/Handler.java → common/src/main/java/net/infumia/pubsub/Handler.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 /**
  * The interface for handling Pub/Sub messages of type {@link T}.

common/src/main/java/tr/com/infumia/pubsub/HandlerRegistry.java → common/src/main/java/net/infumia/pubsub/HandlerRegistry.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.Collection;
 import java.util.concurrent.locks.ReentrantLock;

common/src/main/java/tr/com/infumia/pubsub/HandlerToResponder.java → common/src/main/java/net/infumia/pubsub/HandlerToResponder.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 final class HandlerToResponder<T> implements Responder<T, Object> {
     private final Handler<T> delegate;

common/src/main/java/tr/com/infumia/pubsub/Hex.java → common/src/main/java/net/infumia/pubsub/Hex.java

@@ -19,7 +19,7 @@
  * under the License.
  */
 
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.Objects;
 

common/src/main/java/tr/com/infumia/pubsub/Internal.java → common/src/main/java/net/infumia/pubsub/Internal.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.time.Duration;
 import java.util.UUID;

common/src/main/java/tr/com/infumia/pubsub/Lazy.java → common/src/main/java/net/infumia/pubsub/Lazy.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.function.Supplier;
 

common/src/main/java/tr/com/infumia/pubsub/MultiMap.java → common/src/main/java/net/infumia/pubsub/MultiMap.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.Collection;
 import java.util.HashMap;

common/src/main/java/tr/com/infumia/pubsub/Responder.java → common/src/main/java/net/infumia/pubsub/Responder.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 /**
  * The interface for handling Pub/Sub messages of type {@code T} and providing a response of type {@code Y}.

common/src/main/java/tr/com/infumia/pubsub/Target.java → common/src/main/java/net/infumia/pubsub/Target.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 /**
  * The interface represents message targets.

common/src/main/java/tr/com/infumia/pubsub/TargetImpl.java → common/src/main/java/net/infumia/pubsub/TargetImpl.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 final class TargetImpl implements Target {
     static final Target GLOBAL = Target.of("", "");

common/src/main/java/tr/com/infumia/pubsub/TargetProvider.java → common/src/main/java/net/infumia/pubsub/TargetProvider.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import java.util.Arrays;
 import java.util.Collection;
@@ -24,7 +24,7 @@ static TargetProvider of(final Collection<Target> targets) {
      * @return a newly created target provider.
      */
     static TargetProvider of(final Target... targets) {
-        return TargetProvider.of(Arrays.asList(targets));
+        return of(Arrays.asList(targets));
     }
 
     /**

gradle.properties

@@ -1,5 +1,5 @@
 name=pubsub
-group=tr.com.infumia
+group=net.infumia
 version=1.0.0-SNAPSHOT
 
 org.gradle.parallel=true

kotlin/extensions/build.gradle.kts

@@ -1,7 +1,7 @@
 plugins {
     alias(libs.plugins.kotlin)
     alias(libs.plugins.dokka)
-    id("tr.com.infumia.pubsub.build.publishing")
+    id("net.infumia.pubsub.build.publishing")
 }
 
 dependencies {

kotlin/extensions/src/main/kotlin/tr/com/infumia/pubsub/BrokerExtension.kt → kotlin/extensions/src/main/kotlin/net/infumia/pubsub/BrokerExtension.kt

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub
+package net.infumia.pubsub
 
 import java.util.concurrent.CompletableFuture
 

kotlin/protobuf/build.gradle.kts

@@ -2,7 +2,7 @@ plugins {
     alias(libs.plugins.kotlin)
     alias(libs.plugins.kotlin.serialization)
     alias(libs.plugins.dokka)
-    id("tr.com.infumia.pubsub.build.publishing")
+    id("net.infumia.pubsub.build.publishing")
 }
 
 dependencies {

kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodec.kt → kotlin/protobuf/src/main/kotlin/net/infumia/pubsub/ProtobufCodec.kt

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub
+package net.infumia.pubsub
 
 import kotlinx.serialization.ExperimentalSerializationApi
 import kotlinx.serialization.KSerializer

kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodecProvider.kt → kotlin/protobuf/src/main/kotlin/net/infumia/pubsub/ProtobufCodecProvider.kt

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub
+package net.infumia.pubsub
 
 import kotlin.reflect.full.createType
 import kotlinx.serialization.ExperimentalSerializationApi

redis/build.gradle.kts

@@ -1,5 +1,5 @@
 plugins {
-    id("tr.com.infumia.pubsub.build.publishing")
+    id("net.infumia.pubsub.build.publishing")
 }
 
 dependencies {

redis/src/main/java/tr/com/infumia/pubsub/BrokerRedis.java → redis/src/main/java/net/infumia/pubsub/BrokerRedis.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import io.lettuce.core.RedisClient;
 import io.lettuce.core.api.StatefulRedisConnection;

redis/src/main/java/tr/com/infumia/pubsub/BrokerRedisNoTargetProvider.java → redis/src/main/java/net/infumia/pubsub/BrokerRedisNoTargetProvider.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 /**
  * A concrete implementation of {@link BrokerRedis} that does not provide a target provider.

redis/src/main/java/tr/com/infumia/pubsub/RedisClientProvider.java → redis/src/main/java/net/infumia/pubsub/RedisClientProvider.java

@@ -1,4 +1,4 @@
-package tr.com.infumia.pubsub;
+package net.infumia.pubsub;
 
 import io.lettuce.core.RedisClient;