feat(mqtt bindings): use common MQTT bindings

#184 #175
asyncapi · Apr 21, 2024 · 7a397f3 · 7a397f3
1 parent 65e9341
commit 7a397f3
Show file tree

Hide file tree

Showing 7 changed files with 7 additions and 213 deletions.
diff --git a/asyncapi-core/src/main/java/com/asyncapi/v2/binding/operation/mqtt/MQTTOperationBinding.java b/asyncapi-core/src/main/java/com/asyncapi/v2/binding/operation/mqtt/MQTTOperationBinding.java
diff --git a/asyncapi-core/src/main/java/com/asyncapi/v2/binding/server/mqtt/MQTTServerBinding.java b/asyncapi-core/src/main/java/com/asyncapi/v2/binding/server/mqtt/MQTTServerBinding.java
diff --git a/...re/src/main/java/com/asyncapi/v2/binding/server/mqtt/MQTTServerLastWillConfiguration.java b/...re/src/main/java/com/asyncapi/v2/binding/server/mqtt/MQTTServerLastWillConfiguration.java
diff --git a/...core/src/main/java/com/asyncapi/v2/jackson/binding/server/ServerBindingsDeserializer.java b/...core/src/main/java/com/asyncapi/v2/jackson/binding/server/ServerBindingsDeserializer.java
@@ -10,7 +10,7 @@
 import com.asyncapi.v2.binding.server.jms.JMSServerBinding;
 import com.asyncapi.v2.binding.server.kafka.KafkaServerBinding;
 import com.asyncapi.v2.binding.server.mercure.MercureServerBinding;
-import com.asyncapi.v2.binding.server.mqtt.MQTTServerBinding;
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerBinding;
 import com.asyncapi.bindings.mqtt5.v0._2_0.server.MQTT5ServerBinding;
 import com.asyncapi.bindings.nats.v0._1_0.server.NATSServerBinding;
 import com.asyncapi.bindings.pulsar.v0._1_0.server.PulsarServerBinding;

diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/server/ServerTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/server/ServerTest.kt
@@ -10,8 +10,8 @@ import com.asyncapi.v2.binding.server.ibmmq.IBMMQServerBinding
 import com.asyncapi.v2.binding.server.jms.JMSServerBinding
 import com.asyncapi.v2.binding.server.kafka.KafkaServerBinding
 import com.asyncapi.v2.binding.server.mercure.MercureServerBinding
-import com.asyncapi.v2.binding.server.mqtt.MQTTServerBinding
-import com.asyncapi.v2.binding.server.mqtt.MQTTServerLastWillConfiguration
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerBinding
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerLastWillConfiguration
 import com.asyncapi.bindings.mqtt5.v0._2_0.server.MQTT5ServerBinding
 import com.asyncapi.bindings.nats.v0._1_0.server.NATSServerBinding
 import com.asyncapi.bindings.pulsar.v0._1_0.server.PulsarServerBinding

diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/server/ServerTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/server/ServerTest.kt
@@ -11,8 +11,8 @@ import com.asyncapi.v2.binding.server.ibmmq.IBMMQServerBinding
 import com.asyncapi.v2.binding.server.jms.JMSServerBinding
 import com.asyncapi.v2.binding.server.kafka.KafkaServerBinding
 import com.asyncapi.v2.binding.server.mercure.MercureServerBinding
-import com.asyncapi.v2.binding.server.mqtt.MQTTServerBinding
-import com.asyncapi.v2.binding.server.mqtt.MQTTServerLastWillConfiguration
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerBinding
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerLastWillConfiguration
 import com.asyncapi.bindings.mqtt5.v0._2_0.server.MQTT5ServerBinding
 import com.asyncapi.bindings.nats.v0._1_0.server.NATSServerBinding
 import com.asyncapi.bindings.pulsar.v0._1_0.server.PulsarServerBinding

diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/binding/server/mqtt/MQTTServerBindingTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/binding/server/mqtt/MQTTServerBindingTest.kt
@@ -1,6 +1,8 @@
 package com.asyncapi.v2.binding.server.mqtt
 
 import com.asyncapi.v2.SerDeTest
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerBinding
+import com.asyncapi.bindings.mqtt.v0._1_0.server.MQTTServerLastWillConfiguration
 
 /**
  * @version 2.6.0