diff --git a/README.md b/README.md index 9c44ad2..e416a60 100644 --- a/README.md +++ b/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/ diff --git a/buildSrc/src/main/kotlin/tr.com.infumia.pubsub.build.publishing.gradle.kts b/buildSrc/src/main/kotlin/net.infumia.pubsub.build.publishing.gradle.kts similarity index 100% rename from buildSrc/src/main/kotlin/tr.com.infumia.pubsub.build.publishing.gradle.kts rename to buildSrc/src/main/kotlin/net.infumia.pubsub.build.publishing.gradle.kts diff --git a/common/build.gradle.kts b/common/build.gradle.kts index 5e64f68..7245f0b 100644 --- a/common/build.gradle.kts +++ b/common/build.gradle.kts @@ -1,5 +1,5 @@ plugins { - id("tr.com.infumia.pubsub.build.publishing") + id("net.infumia.pubsub.build.publishing") } dependencies { diff --git a/common/src/main/java/tr/com/infumia/pubsub/AwaitingResponder.java b/common/src/main/java/net/infumia/pubsub/AwaitingResponder.java similarity index 94% rename from common/src/main/java/tr/com/infumia/pubsub/AwaitingResponder.java rename to common/src/main/java/net/infumia/pubsub/AwaitingResponder.java index e0aa8ac..dcd709c 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/AwaitingResponder.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Broker.java b/common/src/main/java/net/infumia/pubsub/Broker.java similarity index 99% rename from common/src/main/java/tr/com/infumia/pubsub/Broker.java rename to common/src/main/java/net/infumia/pubsub/Broker.java index 9ad918e..cf3303c 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Broker.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/BrokerStringAbstract.java b/common/src/main/java/net/infumia/pubsub/BrokerStringAbstract.java similarity index 99% rename from common/src/main/java/tr/com/infumia/pubsub/BrokerStringAbstract.java rename to common/src/main/java/net/infumia/pubsub/BrokerStringAbstract.java index 3b2deb3..7a00ab9 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/BrokerStringAbstract.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Codec.java b/common/src/main/java/net/infumia/pubsub/Codec.java similarity index 95% rename from common/src/main/java/tr/com/infumia/pubsub/Codec.java rename to common/src/main/java/net/infumia/pubsub/Codec.java index dae6f1a..92c90b7 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Codec.java +++ b/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. diff --git a/common/src/main/java/tr/com/infumia/pubsub/CodecProvider.java b/common/src/main/java/net/infumia/pubsub/CodecProvider.java similarity index 93% rename from common/src/main/java/tr/com/infumia/pubsub/CodecProvider.java rename to common/src/main/java/net/infumia/pubsub/CodecProvider.java index b5ef540..ad57fc2 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/CodecProvider.java +++ b/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. diff --git a/common/src/main/java/tr/com/infumia/pubsub/CodecProviderCached.java b/common/src/main/java/net/infumia/pubsub/CodecProviderCached.java similarity index 95% rename from common/src/main/java/tr/com/infumia/pubsub/CodecProviderCached.java rename to common/src/main/java/net/infumia/pubsub/CodecProviderCached.java index 7a2f647..f5e51eb 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/CodecProviderCached.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Envelope.java b/common/src/main/java/net/infumia/pubsub/Envelope.java similarity index 97% rename from common/src/main/java/tr/com/infumia/pubsub/Envelope.java rename to common/src/main/java/net/infumia/pubsub/Envelope.java index ce5781f..b81a1e1 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Envelope.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Handler.java b/common/src/main/java/net/infumia/pubsub/Handler.java similarity index 94% rename from common/src/main/java/tr/com/infumia/pubsub/Handler.java rename to common/src/main/java/net/infumia/pubsub/Handler.java index be35f7f..bdecd93 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Handler.java +++ b/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}. diff --git a/common/src/main/java/tr/com/infumia/pubsub/HandlerRegistry.java b/common/src/main/java/net/infumia/pubsub/HandlerRegistry.java similarity index 97% rename from common/src/main/java/tr/com/infumia/pubsub/HandlerRegistry.java rename to common/src/main/java/net/infumia/pubsub/HandlerRegistry.java index 1958076..7fbc50b 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/HandlerRegistry.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/HandlerToResponder.java b/common/src/main/java/net/infumia/pubsub/HandlerToResponder.java similarity index 92% rename from common/src/main/java/tr/com/infumia/pubsub/HandlerToResponder.java rename to common/src/main/java/net/infumia/pubsub/HandlerToResponder.java index 43578c9..4b22251 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/HandlerToResponder.java +++ b/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 implements Responder { private final Handler delegate; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Hex.java b/common/src/main/java/net/infumia/pubsub/Hex.java similarity index 99% rename from common/src/main/java/tr/com/infumia/pubsub/Hex.java rename to common/src/main/java/net/infumia/pubsub/Hex.java index 2653fb9..93f2c9b 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Hex.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Internal.java b/common/src/main/java/net/infumia/pubsub/Internal.java similarity index 98% rename from common/src/main/java/tr/com/infumia/pubsub/Internal.java rename to common/src/main/java/net/infumia/pubsub/Internal.java index 870bc83..9c8eeae 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Internal.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Lazy.java b/common/src/main/java/net/infumia/pubsub/Lazy.java similarity index 95% rename from common/src/main/java/tr/com/infumia/pubsub/Lazy.java rename to common/src/main/java/net/infumia/pubsub/Lazy.java index c833ae8..c1bc7f0 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Lazy.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/MultiMap.java b/common/src/main/java/net/infumia/pubsub/MultiMap.java similarity index 96% rename from common/src/main/java/tr/com/infumia/pubsub/MultiMap.java rename to common/src/main/java/net/infumia/pubsub/MultiMap.java index 84670b3..2fbc725 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/MultiMap.java +++ b/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; diff --git a/common/src/main/java/tr/com/infumia/pubsub/Responder.java b/common/src/main/java/net/infumia/pubsub/Responder.java similarity index 95% rename from common/src/main/java/tr/com/infumia/pubsub/Responder.java rename to common/src/main/java/net/infumia/pubsub/Responder.java index eb91cf7..7c4cff3 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Responder.java +++ b/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}. diff --git a/common/src/main/java/tr/com/infumia/pubsub/Target.java b/common/src/main/java/net/infumia/pubsub/Target.java similarity index 96% rename from common/src/main/java/tr/com/infumia/pubsub/Target.java rename to common/src/main/java/net/infumia/pubsub/Target.java index 8296c09..e4ac59d 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/Target.java +++ b/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. diff --git a/common/src/main/java/tr/com/infumia/pubsub/TargetImpl.java b/common/src/main/java/net/infumia/pubsub/TargetImpl.java similarity index 93% rename from common/src/main/java/tr/com/infumia/pubsub/TargetImpl.java rename to common/src/main/java/net/infumia/pubsub/TargetImpl.java index b328f0d..abe11bf 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/TargetImpl.java +++ b/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("", ""); diff --git a/common/src/main/java/tr/com/infumia/pubsub/TargetProvider.java b/common/src/main/java/net/infumia/pubsub/TargetProvider.java similarity index 89% rename from common/src/main/java/tr/com/infumia/pubsub/TargetProvider.java rename to common/src/main/java/net/infumia/pubsub/TargetProvider.java index 570e276..35c4b05 100644 --- a/common/src/main/java/tr/com/infumia/pubsub/TargetProvider.java +++ b/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 targets) { * @return a newly created target provider. */ static TargetProvider of(final Target... targets) { - return TargetProvider.of(Arrays.asList(targets)); + return of(Arrays.asList(targets)); } /** diff --git a/gradle.properties b/gradle.properties index ee79197..6483eef 100644 --- a/gradle.properties +++ b/gradle.properties @@ -1,5 +1,5 @@ name=pubsub -group=tr.com.infumia +group=net.infumia version=1.0.0-SNAPSHOT org.gradle.parallel=true diff --git a/kotlin/extensions/build.gradle.kts b/kotlin/extensions/build.gradle.kts index 03d94b2..aa33a32 100644 --- a/kotlin/extensions/build.gradle.kts +++ b/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 { diff --git a/kotlin/extensions/src/main/kotlin/tr/com/infumia/pubsub/BrokerExtension.kt b/kotlin/extensions/src/main/kotlin/net/infumia/pubsub/BrokerExtension.kt similarity index 97% rename from kotlin/extensions/src/main/kotlin/tr/com/infumia/pubsub/BrokerExtension.kt rename to kotlin/extensions/src/main/kotlin/net/infumia/pubsub/BrokerExtension.kt index 543c370..4a45f57 100644 --- a/kotlin/extensions/src/main/kotlin/tr/com/infumia/pubsub/BrokerExtension.kt +++ b/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 diff --git a/kotlin/protobuf/build.gradle.kts b/kotlin/protobuf/build.gradle.kts index cd88b36..189a664 100644 --- a/kotlin/protobuf/build.gradle.kts +++ b/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 { diff --git a/kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodec.kt b/kotlin/protobuf/src/main/kotlin/net/infumia/pubsub/ProtobufCodec.kt similarity index 94% rename from kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodec.kt rename to kotlin/protobuf/src/main/kotlin/net/infumia/pubsub/ProtobufCodec.kt index 6f3fcd1..8039602 100644 --- a/kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodec.kt +++ b/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 diff --git a/kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodecProvider.kt b/kotlin/protobuf/src/main/kotlin/net/infumia/pubsub/ProtobufCodecProvider.kt similarity index 94% rename from kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodecProvider.kt rename to kotlin/protobuf/src/main/kotlin/net/infumia/pubsub/ProtobufCodecProvider.kt index 21df040..2dbeb4f 100644 --- a/kotlin/protobuf/src/main/kotlin/tr/com/infumia/pubsub/ProtobufCodecProvider.kt +++ b/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 diff --git a/redis/build.gradle.kts b/redis/build.gradle.kts index 5bc15fb..ed81a4d 100644 --- a/redis/build.gradle.kts +++ b/redis/build.gradle.kts @@ -1,5 +1,5 @@ plugins { - id("tr.com.infumia.pubsub.build.publishing") + id("net.infumia.pubsub.build.publishing") } dependencies { diff --git a/redis/src/main/java/tr/com/infumia/pubsub/BrokerRedis.java b/redis/src/main/java/net/infumia/pubsub/BrokerRedis.java similarity index 99% rename from redis/src/main/java/tr/com/infumia/pubsub/BrokerRedis.java rename to redis/src/main/java/net/infumia/pubsub/BrokerRedis.java index 29a4567..c756332 100644 --- a/redis/src/main/java/tr/com/infumia/pubsub/BrokerRedis.java +++ b/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; diff --git a/redis/src/main/java/tr/com/infumia/pubsub/BrokerRedisNoTargetProvider.java b/redis/src/main/java/net/infumia/pubsub/BrokerRedisNoTargetProvider.java similarity index 95% rename from redis/src/main/java/tr/com/infumia/pubsub/BrokerRedisNoTargetProvider.java rename to redis/src/main/java/net/infumia/pubsub/BrokerRedisNoTargetProvider.java index bb1025d..036153c 100644 --- a/redis/src/main/java/tr/com/infumia/pubsub/BrokerRedisNoTargetProvider.java +++ b/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. diff --git a/redis/src/main/java/tr/com/infumia/pubsub/RedisClientProvider.java b/redis/src/main/java/net/infumia/pubsub/RedisClientProvider.java similarity index 90% rename from redis/src/main/java/tr/com/infumia/pubsub/RedisClientProvider.java rename to redis/src/main/java/net/infumia/pubsub/RedisClientProvider.java index a412a3e..8ccb3d8 100644 --- a/redis/src/main/java/tr/com/infumia/pubsub/RedisClientProvider.java +++ b/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;