Fix the split package between the smallrye-reactive-messaging-jackson and smallrye-reactive-messaging-jsonb modules

smallrye-reactive-messaging-jackson/src/main/java/io/smallrye/reactive/messaging/json/JacksonMapping.java → smallrye-reactive-messaging-jackson/src/main/java/io/smallrye/reactive/messaging/json/jackson/JacksonMapping.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import jakarta.annotation.Priority;
 import jakarta.enterprise.context.ApplicationScoped;
@@ -7,6 +7,8 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
+import io.smallrye.reactive.messaging.json.JsonMapping;
+
 @ApplicationScoped
 @Priority(value = JsonMapping.DEFAULT_PRIORITY)
 public class JacksonMapping implements JsonMapping {

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/JacksonMappingTest.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/JacksonMappingTest.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import static org.assertj.core.api.Assertions.assertThat;
 

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/JmsConnectorTest.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/JmsConnectorTest.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/ObjectMapperProvider.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/ObjectMapperProvider.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.inject.Produces;

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/Person.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/Person.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 public class Person {
 

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/PersonConsumerBean.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/PersonConsumerBean.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import java.util.ArrayList;
 import java.util.List;

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/PersonProducerBean.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/PersonProducerBean.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import jakarta.enterprise.context.ApplicationScoped;
 

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/TestObject.java → smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/jackson/TestObject.java

@@ -1,7 +1,9 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jackson;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 
+import io.smallrye.reactive.messaging.json.JsonMapping;
+
 /**
  * Test object to use in {@link JsonMapping} implementation.
  */

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/support/JmsTestBase.java

@@ -9,8 +9,8 @@
 import io.smallrye.config.SmallRyeConfigProviderResolver;
 import io.smallrye.config.inject.ConfigExtension;
 import io.smallrye.reactive.messaging.jms.JmsConnector;
-import io.smallrye.reactive.messaging.json.JacksonMapping;
-import io.smallrye.reactive.messaging.json.ObjectMapperProvider;
+import io.smallrye.reactive.messaging.json.jackson.JacksonMapping;
+import io.smallrye.reactive.messaging.json.jackson.ObjectMapperProvider;
 import io.smallrye.reactive.messaging.providers.MediatorFactory;
 import io.smallrye.reactive.messaging.providers.connectors.ExecutionHolder;
 import io.smallrye.reactive.messaging.providers.connectors.WorkerPoolRegistry;

smallrye-reactive-messaging-jsonb/src/main/java/io/smallrye/reactive/messaging/json/JsonBMapping.java → smallrye-reactive-messaging-jsonb/src/main/java/io/smallrye/reactive/messaging/json/jsonb/JsonBMapping.java

@@ -1,10 +1,12 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import jakarta.annotation.Priority;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import jakarta.json.bind.Jsonb;
 
+import io.smallrye.reactive.messaging.json.JsonMapping;
+
 @ApplicationScoped
 @Priority(value = JsonMapping.DEFAULT_PRIORITY + 1)
 public class JsonBMapping implements JsonMapping {

smallrye-reactive-messaging-jackson/src/test/java/io/smallrye/reactive/messaging/json/JmsConnectorTest.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/JmsConnectorTest.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/JsonBMappingTest.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/JsonBMappingTest.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import static org.assertj.core.api.Assertions.assertThat;
 

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/JsonBProvider.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/JsonBProvider.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.inject.Produces;

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/Person.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/Person.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 public class Person {
 

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/PersonConsumerBean.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/PersonConsumerBean.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import java.util.ArrayList;
 import java.util.List;

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/PersonProducerBean.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/PersonProducerBean.java

@@ -1,4 +1,4 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import jakarta.enterprise.context.ApplicationScoped;
 

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/TestObject.java → smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/json/jsonb/TestObject.java

@@ -1,7 +1,9 @@
-package io.smallrye.reactive.messaging.json;
+package io.smallrye.reactive.messaging.json.jsonb;
 
 import jakarta.json.bind.annotation.JsonbProperty;
 
+import io.smallrye.reactive.messaging.json.JsonMapping;
+
 /**
  * Test object to use in {@link JsonMapping} implementation.
  */

smallrye-reactive-messaging-jsonb/src/test/java/io/smallrye/reactive/messaging/support/JmsTestBase.java

@@ -9,8 +9,8 @@
 import io.smallrye.config.SmallRyeConfigProviderResolver;
 import io.smallrye.config.inject.ConfigExtension;
 import io.smallrye.reactive.messaging.jms.JmsConnector;
-import io.smallrye.reactive.messaging.json.JsonBMapping;
-import io.smallrye.reactive.messaging.json.JsonBProvider;
+import io.smallrye.reactive.messaging.json.jsonb.JsonBMapping;
+import io.smallrye.reactive.messaging.json.jsonb.JsonBProvider;
 import io.smallrye.reactive.messaging.providers.MediatorFactory;
 import io.smallrye.reactive.messaging.providers.connectors.ExecutionHolder;
 import io.smallrye.reactive.messaging.providers.connectors.WorkerPoolRegistry;

smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/DynamicMqttTopicSourceTest.java

@@ -48,6 +48,10 @@ private void awaitAndVerify() {
                 .pollInterval(Duration.ofSeconds(1))
                 .until(() -> connector.getReadiness().isOk());
 
+        await()
+                .pollInterval(Duration.ofSeconds(1))
+                .until(() -> connector.getLiveness().isOk());
+
         bean.publish();
 
         await().until(() -> bean.messages().size() >= 3);
@@ -155,23 +159,36 @@ public void publish() {
             emitter.send(MqttMessage
                     .of("/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 1",
                             MqttQoS.EXACTLY_ONCE));
+            nap(10);
             emitter.send(MqttMessage
                     .of("/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 2",
                             MqttQoS.EXACTLY_ONCE));
+            nap(10);
             emitter.send(MqttMessage
                     .of("/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 3",
                             MqttQoS.EXACTLY_ONCE));
+            nap(15);
             emitter.send(MqttMessage
                     .of("$/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 4",
                             MqttQoS.EXACTLY_ONCE));
+            nap(10);
             emitter.send(MqttMessage
                     .of("$/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 5",
                             MqttQoS.EXACTLY_ONCE));
+            nap(5);
             emitter.send(MqttMessage
                     .of("$/app/hello/mqtt-" + LocalDate.now().toString() + "/greeting", "hello from dynamic topic 6",
                             MqttQoS.EXACTLY_ONCE));
         }
 
+        private void nap(int duration) {
+            try {
+                Thread.sleep(duration);
+            } catch (Exception ignored) {
+                // ignored.
+            }
+        }
+
         @Incoming("in")
         public CompletionStage<Void> received(MqttMessage<byte[]> message) {
             messages.add(message);