diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ChannelBindingsDeserializer.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ChannelBindingsDeserializer.java index 8066517e..50a3d23c 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/ChannelBindingsDeserializer.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ChannelBindingsDeserializer.java @@ -5,7 +5,7 @@ import com.asyncapi.bindings.anypointmq.AnypointMQChannelBinding; import com.asyncapi.bindings.googlepubsub.GooglePubSubChannelBinding; import com.asyncapi.bindings.http.HTTPChannelBinding; -import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding; +import com.asyncapi.bindings.ibmmq.IBMMQChannelBinding; import com.asyncapi.bindings.jms.v0._0_1.channel.JMSChannelBinding; import com.asyncapi.bindings.kafka.v0._4_0.channel.KafkaChannelBinding; import com.asyncapi.bindings.mercure.v0._1_0.channel.MercureChannelBinding; diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/MessageBindingsDeserializer.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/MessageBindingsDeserializer.java index 7c61eab9..e989f668 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/MessageBindingsDeserializer.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/MessageBindingsDeserializer.java @@ -5,7 +5,7 @@ import com.asyncapi.bindings.anypointmq.AnypointMQMessageBinding; import com.asyncapi.bindings.googlepubsub.GooglePubSubMessageBinding; import com.asyncapi.bindings.http.HTTPMessageBinding; -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding; +import com.asyncapi.bindings.ibmmq.IBMMQMessageBinding; import com.asyncapi.bindings.jms.v0._0_1.message.JMSMessageBinding; import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBinding; import com.asyncapi.bindings.mercure.v0._1_0.message.MercureMessageBinding; diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/OperationBindingsDeserializer.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/OperationBindingsDeserializer.java index 0f10a5b0..1c3c1309 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/OperationBindingsDeserializer.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/OperationBindingsDeserializer.java @@ -5,7 +5,7 @@ import com.asyncapi.bindings.anypointmq.AnypointMQOperationBinding; import com.asyncapi.bindings.googlepubsub.GooglePubSubOperationBinding; import com.asyncapi.bindings.http.HTTPOperationBinding; -import com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding; +import com.asyncapi.bindings.ibmmq.IBMMQOperationBinding; import com.asyncapi.bindings.jms.v0._0_1.operation.JMSOperationBinding; import com.asyncapi.bindings.kafka.v0._4_0.operation.KafkaOperationBinding; import com.asyncapi.bindings.mercure.v0._1_0.operation.MercureOperationBinding; diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ServerBindingsDeserializer.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ServerBindingsDeserializer.java index 24d516d8..9dfd96ae 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/ServerBindingsDeserializer.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ServerBindingsDeserializer.java @@ -5,7 +5,7 @@ import com.asyncapi.bindings.anypointmq.AnypointMQServerBinding; import com.asyncapi.bindings.googlepubsub.GooglePubSubServerBinding; import com.asyncapi.bindings.http.HTTPServerBinding; -import com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding; +import com.asyncapi.bindings.ibmmq.IBMMQServerBinding; import com.asyncapi.bindings.jms.v0._0_1.server.JMSServerBinding; import com.asyncapi.bindings.kafka.v0._4_0.server.KafkaServerBinding; import com.asyncapi.bindings.mercure.v0._1_0.server.MercureServerBinding; diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQChannelBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQChannelBinding.java new file mode 100644 index 00000000..40dbc2c7 --- /dev/null +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQChannelBinding.java @@ -0,0 +1,31 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.ChannelBinding; +import com.fasterxml.jackson.annotation.JsonSubTypes; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import lombok.EqualsAndHashCode; + +/** + * Describes IBM MQ channel binding. + *

+ * This object contains information about the channel representation in IBM MQ. Each channel corresponds to a Queue or Topic within IBM MQ. + * + * @version 0.1.0 + * @see IBM MQ channel binding + * @author Pavel Bodiachevskii + */ +@JsonTypeInfo( + use = JsonTypeInfo.Id.NAME, + include = JsonTypeInfo.As.EXISTING_PROPERTY, + defaultImpl = com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding.class, + property = "bindingVersion", + visible = true +) +@JsonSubTypes({ + @JsonSubTypes.Type(value = com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding.class, names = { + "0.1.0", + "latest" + }), +}) +@EqualsAndHashCode(callSuper = true) +public class IBMMQChannelBinding extends ChannelBinding {} \ No newline at end of file diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQMessageBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQMessageBinding.java new file mode 100644 index 00000000..81a29d91 --- /dev/null +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQMessageBinding.java @@ -0,0 +1,31 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.MessageBinding; +import com.fasterxml.jackson.annotation.JsonSubTypes; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import lombok.EqualsAndHashCode; + +/** + * Describes IBM MQ message binding. + *

+ * This object contains information about the message representation in IBM MQ. + * + * @version 0.1.0 + * @see IBM MQ message binding + * @author Pavel Bodiachevskii + */ +@JsonTypeInfo( + use = JsonTypeInfo.Id.NAME, + include = JsonTypeInfo.As.EXISTING_PROPERTY, + defaultImpl = com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding.class, + property = "bindingVersion", + visible = true +) +@JsonSubTypes({ + @JsonSubTypes.Type(value = com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding.class, names = { + "0.1.0", + "latest" + }), +}) +@EqualsAndHashCode(callSuper = true) +public class IBMMQMessageBinding extends MessageBinding {} \ No newline at end of file diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQOperationBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQOperationBinding.java new file mode 100644 index 00000000..a6fd25f1 --- /dev/null +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQOperationBinding.java @@ -0,0 +1,31 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.OperationBinding; +import com.fasterxml.jackson.annotation.JsonSubTypes; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import lombok.EqualsAndHashCode; + +/** + * Describes IBM MQ operation binding. + *

+ * This object MUST NOT contain any properties. Its name is reserved for future use. + * + * @version 0.1.0 + * @see IBM MQ operation binding + * @author Pavel Bodiachevskii + */ +@JsonTypeInfo( + use = JsonTypeInfo.Id.NAME, + include = JsonTypeInfo.As.EXISTING_PROPERTY, + defaultImpl = com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding.class, + property = "bindingVersion", + visible = true +) +@JsonSubTypes({ + @JsonSubTypes.Type(value = com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding.class, names = { + "0.1.0", + "latest" + }), +}) +@EqualsAndHashCode(callSuper = true) +public class IBMMQOperationBinding extends OperationBinding {} \ No newline at end of file diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQServerBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQServerBinding.java new file mode 100644 index 00000000..f840543d --- /dev/null +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/IBMMQServerBinding.java @@ -0,0 +1,32 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.ServerBinding; +import com.fasterxml.jackson.annotation.JsonSubTypes; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import lombok.EqualsAndHashCode; + +/** + * Describes IBM MQ server binding. + *

+ * This object contains server connection information about the IBM MQ server, referred to as an IBM MQ queue manager. + * This object contains additional connectivity information not possible to represent within the core AsyncAPI specification. + * + * @version 0.1.0 + * @see IBM MQ server binding + * @author Pavel Bodiachevskii + */ +@JsonTypeInfo( + use = JsonTypeInfo.Id.NAME, + include = JsonTypeInfo.As.EXISTING_PROPERTY, + defaultImpl = com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding.class, + property = "bindingVersion", + visible = true +) +@JsonSubTypes({ + @JsonSubTypes.Type(value = com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding.class, names = { + "0.1.0", + "latest" + }), +}) +@EqualsAndHashCode(callSuper = true) +public class IBMMQServerBinding extends ServerBinding {} \ No newline at end of file diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBinding.java index ecfd1be3..0578168a 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBinding.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBinding.java @@ -22,7 +22,7 @@ @AllArgsConstructor @EqualsAndHashCode(callSuper = true) @JsonClassDescription("Describes IBM MQ channel binding.") -public class IBMMQChannelBinding extends ChannelBinding { +public class IBMMQChannelBinding extends com.asyncapi.bindings.ibmmq.IBMMQChannelBinding { /** * Defines the type of AsyncAPI channel. @@ -77,12 +77,14 @@ public class IBMMQChannelBinding extends ChannelBinding { @JsonPropertyDescription("The maximum length of the physical message (in bytes) accepted by the Topic or Queue. Messages produced that are greater in size than this value may fail to be delivered. More information on the maximum message length can be found on this [page](https://www.ibm.com/support/knowledgecenter/SSFKSJ_latest/com.ibm.mq.ref.dev.doc/q097520_.html) in the IBM MQ Knowledge Center.") private Integer maxMsgLength; - /** - * The version of this binding. - */ - @Builder.Default - @JsonProperty("bindingVersion") - @JsonPropertyDescription("The version of this binding.") - private String bindingVersion = "0.1.0"; + @Override + public String getBindingVersion() { + return "0.1.0"; + } + + @Override + public void setBindingVersion(@Nullable String bindingVersion) { + super.setBindingVersion("0.1.0"); + } } diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBinding.java index ee6730ef..89338f4a 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBinding.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBinding.java @@ -22,7 +22,7 @@ @AllArgsConstructor @EqualsAndHashCode(callSuper = true) @JsonClassDescription("Describes IBM MQ message binding.") -public class IBMMQMessageBinding extends MessageBinding { +public class IBMMQMessageBinding extends com.asyncapi.bindings.ibmmq.IBMMQMessageBinding { /** * The type of the message. @@ -77,13 +77,14 @@ public class IBMMQMessageBinding extends MessageBinding { @JsonPropertyDescription("The recommended setting the client should use for the TTL (Time-To-Live) of the message. This is a period of time expressed in milliseconds and set by the application that puts the message. 'expiry' values are API dependant e.g., MQI and JMS use different units of time and default values for 'unlimited'. General information on IBM MQ message expiry can be found on this [page](https://www.ibm.com/docs/en/ibm-mq/9.2?topic=mqmd-expiry-mqlong) in the IBM MQ Knowledge Center.") private Integer expiry = 0; - /** - * The version of this binding. - */ - @Nullable - @Builder.Default - @JsonProperty("bindingVersion") - @JsonPropertyDescription("The version of this binding.") - private String bindingVersion = "0.1.0"; + @Override + public String getBindingVersion() { + return "0.1.0"; + } + + @Override + public void setBindingVersion(@Nullable String bindingVersion) { + super.setBindingVersion("0.1.0"); + } } diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/operation/IBMMQOperationBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/operation/IBMMQOperationBinding.java index c72a96d4..9a6d25f9 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/operation/IBMMQOperationBinding.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/operation/IBMMQOperationBinding.java @@ -5,6 +5,7 @@ import lombok.Data; import lombok.EqualsAndHashCode; import lombok.NoArgsConstructor; +import org.jetbrains.annotations.Nullable; /** * Describes IBM MQ operation binding. @@ -19,5 +20,16 @@ @Builder @NoArgsConstructor @EqualsAndHashCode(callSuper = true) -public class IBMMQOperationBinding extends OperationBinding { +public class IBMMQOperationBinding extends com.asyncapi.bindings.ibmmq.IBMMQOperationBinding { + + @Override + public String getBindingVersion() { + return "0.1.0"; + } + + @Override + public void setBindingVersion(@Nullable String bindingVersion) { + super.setBindingVersion("0.1.0"); + } + } diff --git a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBinding.java b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBinding.java index c965fd4c..5c20fc38 100644 --- a/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBinding.java +++ b/asyncapi-core/src/main/java/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBinding.java @@ -23,7 +23,7 @@ @AllArgsConstructor @EqualsAndHashCode(callSuper = true) @JsonClassDescription("Describes IBM MQ server binding.") -public class IBMMQServerBinding extends ServerBinding { +public class IBMMQServerBinding extends com.asyncapi.bindings.ibmmq.IBMMQServerBinding { /** * Defines a logical group of IBM MQ server objects. This is necessary to specify multi-endpoint configurations used @@ -91,12 +91,14 @@ public class IBMMQServerBinding extends ServerBinding { @JsonPropertyDescription("The recommended value (in seconds) for the heartbeat sent to the queue manager during periods of inactivity. A value of zero means that no heart beats are sent. A value of 1 means that the client will use the value defined by the queue manager.") private int heartBeatInterval = 300; - /** - * The version of this binding. - */ - @Builder.Default - @JsonProperty("bindingVersion") - @JsonPropertyDescription("The version of this binding.") - private String bindingVersion = "0.1.0"; + @Override + public String getBindingVersion() { + return "0.1.0"; + } + + @Override + public void setBindingVersion(@Nullable String bindingVersion) { + super.setBindingVersion("0.1.0"); + } } diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQ.java b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQ.java new file mode 100644 index 00000000..45a45946 --- /dev/null +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQ.java @@ -0,0 +1,11 @@ +package com.asyncapi.bindings.ibmmq; + +import org.junit.platform.suite.api.SelectPackages; +import org.junit.platform.suite.api.Suite; +import org.junit.platform.suite.api.SuiteDisplayName; + +@Suite +@SuiteDisplayName("IBM MQ") +@SelectPackages("com.asyncapi.bindings.ibmmq") +public class IBMMQ { +} diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQLatestTest.java b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQLatestTest.java new file mode 100644 index 00000000..7af44264 --- /dev/null +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQLatestTest.java @@ -0,0 +1,54 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.BindingTest; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Nested; + +@DisplayName("latest") +public class IBMMQLatestTest { + + @Nested + @DisplayName("channel") + class ChannelTest extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.channelBinding(); + super.bindingTypeClass = IBMMQChannelBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/latest/channel/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/latest/channel/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/latest/channel/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("message") + class Message extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.messageBinding(); + super.bindingTypeClass = IBMMQMessageBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/latest/message/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/latest/message/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/latest/message/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("operation") + class Operation extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.operationBinding(); + super.bindingTypeClass = IBMMQOperationBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/latest/operation/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/latest/operation/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/latest/operation/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("server") + class Server extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.serverBinding(); + super.bindingTypeClass = IBMMQServerBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/latest/server/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/latest/server/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/latest/server/binding - wrongly extended.json"; + }} + +} diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQUnknownVersionTest.java b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQUnknownVersionTest.java new file mode 100644 index 00000000..e6d90d46 --- /dev/null +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQUnknownVersionTest.java @@ -0,0 +1,54 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.BindingTest; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Nested; + +@DisplayName("unknown version") +public class IBMMQUnknownVersionTest { + + @Nested + @DisplayName("channel") + class ChannelTest extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.channelBinding(); + super.bindingTypeClass = IBMMQChannelBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/unknown version/channel/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/unknown version/channel/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/unknown version/channel/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("message") + class Message extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.messageBinding(); + super.bindingTypeClass = IBMMQMessageBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/unknown version/message/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/unknown version/message/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/unknown version/message/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("operation") + class Operation extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.operationBinding(); + super.bindingTypeClass = IBMMQOperationBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/unknown version/operation/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/unknown version/operation/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/unknown version/operation/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("server") + class Server extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.serverBinding(); + super.bindingTypeClass = IBMMQServerBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/unknown version/server/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/unknown version/server/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/unknown version/server/binding - wrongly extended.json"; + }} + +} diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQV0_1_0Test.java b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQV0_1_0Test.java new file mode 100644 index 00000000..ceb55a48 --- /dev/null +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQV0_1_0Test.java @@ -0,0 +1,98 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.BindingTest; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelDestinationType; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelQueueProperties; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelTopicProperties; +import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageType; +import com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Nested; + +@DisplayName("0.1.0") +public class IBMMQV0_1_0Test { + + public static IBMMQChannelBinding channelBinding () { + return IBMMQChannelBinding.builder() + .destinationType(IBMMQChannelDestinationType.TOPIC) + .queue(IBMMQChannelQueueProperties.builder() + .objectName("message") + .isPartitioned(false) + .exclusive(true) + .build() + ) + .topic(IBMMQChannelTopicProperties.builder() + .string("messages") + .objectName("message") + .durablePermitted(true) + .lastMsgRetained(true) + .build() + ) + .maxMsgLength(1024) + .build(); + } + + public static IBMMQMessageBinding messageBinding () { + return IBMMQMessageBinding.builder() + .type(IBMMQMessageType.JMS) + .description("JMS stream message") + .headers("Content-Type: application/json") + .expiry(0) + .build(); + } + + public static IBMMQOperationBinding operationBinding () { + return new IBMMQOperationBinding(); + } + + public static IBMMQServerBinding serverBinding () { + return IBMMQServerBinding.builder() + .groupId("PRODCLSTR1") + .cipherSpec("ANY_TLS12_OR_HIGHER") + .build(); + } + + @Nested + @DisplayName("channel") + class ChannelTest extends BindingTest {{ + super.binding = channelBinding(); + super.bindingTypeClass = IBMMQChannelBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/0.1.0/channel/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/0.1.0/channel/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/0.1.0/channel/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("message") + class Message extends BindingTest {{ + super.binding = messageBinding(); + super.bindingTypeClass = IBMMQMessageBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/0.1.0/message/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/0.1.0/message/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/0.1.0/message/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("operation") + class Operation extends BindingTest {{ + super.binding = operationBinding(); + super.bindingTypeClass = IBMMQOperationBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/0.1.0/operation/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/0.1.0/operation/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/0.1.0/operation/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("server") + class Server extends BindingTest {{ + super.binding = serverBinding(); + super.bindingTypeClass = IBMMQServerBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/0.1.0/server/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/0.1.0/server/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/0.1.0/server/binding - wrongly extended.json"; + }} + +} diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQWithoutVersionTest.java b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQWithoutVersionTest.java new file mode 100644 index 00000000..aa20ca27 --- /dev/null +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/IBMMQWithoutVersionTest.java @@ -0,0 +1,54 @@ +package com.asyncapi.bindings.ibmmq; + +import com.asyncapi.bindings.BindingTest; +import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.operation.IBMMQOperationBinding; +import com.asyncapi.bindings.ibmmq.v0._1_0.server.IBMMQServerBinding; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Nested; + +@DisplayName("without version") +public class IBMMQWithoutVersionTest { + + @Nested + @DisplayName("channel") + class ChannelTest extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.channelBinding(); + super.bindingTypeClass = IBMMQChannelBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/without version/channel/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/without version/channel/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/without version/channel/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("message") + class Message extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.messageBinding(); + super.bindingTypeClass = IBMMQMessageBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/without version/message/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/without version/message/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/without version/message/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("operation") + class Operation extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.operationBinding(); + super.bindingTypeClass = IBMMQOperationBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/without version/operation/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/without version/operation/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/without version/operation/binding - wrongly extended.json"; + }} + + @Nested + @DisplayName("server") + class Server extends BindingTest {{ + super.binding = IBMMQV0_1_0Test.serverBinding(); + super.bindingTypeClass = IBMMQServerBinding.class; + super.pathToBindingJson = "/bindings/ibmmq/without version/server/binding.json"; + super.pathToExtendedBindingJson = "/bindings/ibmmq/without version/server/binding - extended.json"; + super.pathToWronglyExtendedBindingJson = "/bindings/ibmmq/without version/server/binding - wrongly extended.json"; + }} + +} diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBindingTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBindingTest.kt deleted file mode 100644 index 87cc443e..00000000 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/channel/IBMMQChannelBindingTest.kt +++ /dev/null @@ -1,35 +0,0 @@ -package com.asyncapi.bindings.ibmmq.v0._1_0.channel - -import com.asyncapi.v3.SerDeTest - -class IBMMQChannelBindingTest: SerDeTest() { - - override fun objectClass() = IBMMQChannelBinding::class.java - - override fun baseObjectJson() = "/bindings/ibmmq/channel/ibmMQChannelBinding.json" - - override fun extendedObjectJson() = "/bindings/ibmmq/channel/ibmMQChannelBinding - extended.json" - - override fun wronglyExtendedObjectJson() = "/bindings/ibmmq/channel/ibmMQChannelBinding - wrongly extended.json" - - override fun build(): IBMMQChannelBinding { - return IBMMQChannelBinding.builder() - .destinationType(IBMMQChannelDestinationType.TOPIC) - .queue(IBMMQChannelQueueProperties.builder() - .objectName("message") - .isPartitioned(false) - .exclusive(true) - .build() - ) - .topic(IBMMQChannelTopicProperties.builder() - .string("messages") - .objectName("message") - .durablePermitted(true) - .lastMsgRetained(true) - .build() - ) - .maxMsgLength(1024) - .build() - } - -} \ No newline at end of file diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBindingTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBindingTest.kt deleted file mode 100644 index 54356285..00000000 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/message/IBMMQMessageBindingTest.kt +++ /dev/null @@ -1,24 +0,0 @@ -package com.asyncapi.bindings.ibmmq.v0._1_0.message - -import com.asyncapi.v3.SerDeTest - -class IBMMQMessageBindingTest: SerDeTest() { - - override fun objectClass() = IBMMQMessageBinding::class.java - - override fun baseObjectJson() = "/bindings/ibmmq/message/ibmMQMessageBinding.json" - - override fun extendedObjectJson() = "/bindings/ibmmq/message/ibmMQMessageBinding - extended.json" - - override fun wronglyExtendedObjectJson() = "/bindings/ibmmq/message/ibmMQMessageBinding - wrongly extended.json" - - override fun build(): IBMMQMessageBinding { - return IBMMQMessageBinding.builder() - .type(IBMMQMessageType.JMS) - .description("JMS stream message") - .headers("Content-Type: application/json") - .expiry(0) - .build() - } - -} \ No newline at end of file diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBindingTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBindingTest.kt deleted file mode 100644 index b5fb9f5f..00000000 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/bindings/ibmmq/v0/_1_0/server/IBMMQServerBindingTest.kt +++ /dev/null @@ -1,26 +0,0 @@ -package com.asyncapi.bindings.ibmmq.v0._1_0.server - -import com.asyncapi.v3.SerDeTest - -/** - * @version 3.0.0 - * @author Pavel Bodiachevskii - */ -class IBMMQServerBindingTest: SerDeTest() { - - override fun objectClass() = IBMMQServerBinding::class.java - - override fun baseObjectJson() = "/bindings/ibmmq/server/ibmmqServerBinding.json" - - override fun extendedObjectJson() = "/bindings/ibmmq/server/ibmmqServerBinding - extended.json" - - override fun wronglyExtendedObjectJson() = "/bindings/ibmmq/server/ibmmqServerBinding - wrongly extended.json" - - override fun build(): IBMMQServerBinding { - return IBMMQServerBinding.builder() - .groupId("PRODCLSTR1") - .cipherSpec("ANY_TLS12_OR_HIGHER") - .build() - } - -} \ No newline at end of file diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/ChannelItemTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/ChannelItemTest.kt index e8327302..ebff2932 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/ChannelItemTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/ChannelItemTest.kt @@ -10,7 +10,7 @@ import com.asyncapi.bindings.amqp1.v0._1_0.channel.AMQP1ChannelBinding import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.jms.v0._0_1.channel.JMSChannelBinding import com.asyncapi.bindings.kafka.v0._4_0.channel.KafkaChannelBindingTest import com.asyncapi.bindings.mercure.v0._1_0.channel.MercureChannelBinding @@ -60,7 +60,7 @@ class ChannelItemTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.channelBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.channelBinding()), Pair("http", HTTPV0_3_0Test.channelBinding()), - Pair("ibmmq", IBMMQChannelBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.channelBinding()), Pair("jms", JMSChannelBinding()), Pair("kafka", KafkaChannelBindingTest().build()), Pair("mercure", MercureChannelBinding()), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTest.kt index 0281c9df..34b9b699 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTest.kt @@ -11,7 +11,7 @@ import com.asyncapi.bindings.amqp1.v0._1_0.message.AMQP1MessageBinding import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.jms.v0._0_1.message.JMSMessageBinding import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBindingTest import com.asyncapi.bindings.mercure.v0._1_0.message.MercureMessageBinding @@ -119,7 +119,7 @@ class MessageTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", JMSMessageBinding()), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", MercureMessageBinding()), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTraitTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTraitTest.kt index cbb673f3..81ae33c2 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTraitTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_0_0/model/channel/message/MessageTraitTest.kt @@ -9,7 +9,7 @@ import com.asyncapi.bindings.amqp1.v0._1_0.message.AMQP1MessageBinding import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.jms.v0._0_1.message.JMSMessageBinding import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBindingTest import com.asyncapi.bindings.mercure.v0._1_0.message.MercureMessageBinding @@ -78,7 +78,7 @@ class MessageTraitTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", JMSMessageBinding()), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", MercureMessageBinding()), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/ChannelItemTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/ChannelItemTest.kt index 93b3cbf8..41ad0112 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/ChannelItemTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/ChannelItemTest.kt @@ -8,7 +8,7 @@ import com.asyncapi.v2.schema.Schema import com.asyncapi.bindings.amqp.AMQPV0_2_0Test import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.kafka.v0._4_0.channel.KafkaChannelBindingTest import com.asyncapi.bindings.pulsar.v0._1_0.channel.PulsarChannelBindingTest import com.asyncapi.bindings.websockets.v0._1_0.WebSocketsBindingProvider @@ -49,7 +49,7 @@ class ChannelItemTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.channelBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.channelBinding()), Pair("http", Reference("#/components/channelBindings/http")), - Pair("ibmmq", IBMMQChannelBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.channelBinding()), Pair("jms", Reference("#/components/channelBindings/jms")), Pair("kafka", KafkaChannelBindingTest().build()), Pair("mercure", Reference("#/components/channelBindings/mercure")), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTest.kt index 4984291d..1c760029 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTest.kt @@ -9,7 +9,7 @@ import com.asyncapi.bindings.amqp.AMQPV0_2_0Test import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBindingTest import com.asyncapi.bindings.mqtt.v0._1_0.message.MQTTMessageBindingTest @@ -93,7 +93,7 @@ class MessageTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", Reference("#/components/messageBindings/mercure")), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTraitTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTraitTest.kt index b0088816..f74b63a6 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTraitTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v2/_6_0/model/channel/message/MessageTraitTest.kt @@ -9,7 +9,7 @@ import com.asyncapi.bindings.amqp.AMQPV0_2_0Test import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBindingTest import com.asyncapi.bindings.mqtt.v0._1_0.message.MQTTMessageBindingTest @@ -65,7 +65,7 @@ class MessageTraitTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", Reference("#/components/messageBindings/mercure")), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/ChannelTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/ChannelTest.kt index c7967c75..ebff0c15 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/ChannelTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/ChannelTest.kt @@ -11,7 +11,7 @@ import com.asyncapi.v3._0_0.model.channel.message.MessageTestWithSchema import com.asyncapi.bindings.amqp.AMQPV0_2_0Test import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.channel.IBMMQChannelBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.kafka.v0._4_0.channel.KafkaChannelBindingTest import com.asyncapi.bindings.pulsar.v0._1_0.channel.PulsarChannelBindingTest import com.asyncapi.bindings.websockets.v0._1_0.WebSocketsBindingProvider @@ -69,7 +69,7 @@ class ChannelTest: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.channelBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.channelBinding()), Pair("http", Reference("#/components/channelBindings/http")), - Pair("ibmmq", IBMMQChannelBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.channelBinding()), Pair("jms", Reference("#/components/channelBindings/jms")), Pair("kafka", KafkaChannelBindingTest().build()), Pair("mercure", Reference("#/components/channelBindings/mercure")), @@ -142,7 +142,7 @@ class ChannelTestWithReference: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.channelBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.channelBinding()), Pair("http", Reference("#/components/channelBindings/http")), - Pair("ibmmq", IBMMQChannelBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.channelBinding()), Pair("jms", Reference("#/components/channelBindings/jms")), Pair("kafka", KafkaChannelBindingTest().build()), Pair("mercure", Reference("#/components/channelBindings/mercure")), diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTest.kt index 58952e88..d6aa3717 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTest.kt @@ -8,7 +8,7 @@ import com.asyncapi.bindings.amqp.AMQPV0_2_0Test import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBindingTest import com.asyncapi.bindings.mqtt.v0._1_0.message.MQTTMessageBindingTest import com.asyncapi.v3.schema.AsyncAPISchema @@ -89,7 +89,7 @@ class MessageTestWithSchema: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", Reference("#/components/messageBindings/mercure")), @@ -142,7 +142,7 @@ class MessageTestWithReference: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", @@ -232,7 +232,7 @@ class MessageTestWithMultiFormatSchema: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", diff --git a/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTraitTest.kt b/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTraitTest.kt index 178d2738..b8238d03 100644 --- a/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTraitTest.kt +++ b/asyncapi-core/src/test/kotlin/com/asyncapi/v3/_0_0/model/channel/message/MessageTraitTest.kt @@ -9,7 +9,7 @@ import com.asyncapi.bindings.amqp.AMQPV0_2_0Test import com.asyncapi.bindings.anypointmq.AnypointMQV0_0_1Test import com.asyncapi.bindings.googlepubsub.GooglePubSubV0_1_0Test import com.asyncapi.bindings.http.HTTPV0_3_0Test -import com.asyncapi.bindings.ibmmq.v0._1_0.message.IBMMQMessageBindingTest +import com.asyncapi.bindings.ibmmq.IBMMQV0_1_0Test import com.asyncapi.bindings.kafka.v0._4_0.message.KafkaMessageBindingTest import com.asyncapi.bindings.mqtt.v0._1_0.message.MQTTMessageBindingTest import com.asyncapi.v3.schema.multiformat.AsyncAPIFormatSchema @@ -64,7 +64,7 @@ class MessageTraitTestWithSchema: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", @@ -119,7 +119,7 @@ class MessageTraitTestWithReference: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", @@ -191,7 +191,7 @@ class MessageTraitTestWithMultiFormatSchema: SerDeTest() { Pair("anypointmq", AnypointMQV0_0_1Test.messageBinding()), Pair("googlepubsub", GooglePubSubV0_1_0Test.messageBinding()), Pair("http", HTTPV0_3_0Test.messageBinding()), - Pair("ibmmq", IBMMQMessageBindingTest().build()), + Pair("ibmmq", IBMMQV0_1_0Test.messageBinding()), Pair("jms", Reference("#/components/messageBindings/jms")), Pair("kafka", KafkaMessageBindingTest().build()), Pair("mercure", diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/channel/ibmMQChannelBinding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/channel/binding - extended.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/channel/ibmMQChannelBinding - extended.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/channel/binding - extended.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/channel/ibmMQChannelBinding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/channel/binding - wrongly extended.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/channel/ibmMQChannelBinding - wrongly extended.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/channel/binding - wrongly extended.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/channel/ibmMQChannelBinding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/channel/binding.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/channel/ibmMQChannelBinding.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/channel/binding.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/message/ibmMQMessageBinding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/message/binding - extended.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/message/ibmMQMessageBinding - extended.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/message/binding - extended.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/message/ibmMQMessageBinding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/message/binding - wrongly extended.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/message/ibmMQMessageBinding - wrongly extended.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/message/binding - wrongly extended.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/message/ibmMQMessageBinding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/message/binding.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/message/ibmMQMessageBinding.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/message/binding.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding - extended.json new file mode 100644 index 00000000..32459b79 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding - extended.json @@ -0,0 +1,8 @@ +{ + "bindingVersion" : "0.1.0", + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding - wrongly extended.json new file mode 100644 index 00000000..a1ecfd51 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding - wrongly extended.json @@ -0,0 +1,9 @@ +{ + "bindingVersion": "0.1.0", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding.json new file mode 100644 index 00000000..04dbf945 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/operation/binding.json @@ -0,0 +1,3 @@ +{ + "bindingVersion": "0.1.0" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/server/ibmmqServerBinding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/server/binding - extended.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/server/ibmmqServerBinding - extended.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/server/binding - extended.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/server/ibmmqServerBinding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/server/binding - wrongly extended.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/server/ibmmqServerBinding - wrongly extended.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/server/binding - wrongly extended.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/server/ibmmqServerBinding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/server/binding.json similarity index 100% rename from asyncapi-core/src/test/resources/bindings/ibmmq/server/ibmmqServerBinding.json rename to asyncapi-core/src/test/resources/bindings/ibmmq/0.1.0/server/binding.json diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding - extended.json new file mode 100644 index 00000000..f3e6ae31 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding - extended.json @@ -0,0 +1,21 @@ +{ + "bindingVersion" : "0.1.0", + "destinationType" : "topic", + "queue" : { + "objectName" : "message", + "isPartitioned" : false, + "exclusive" : true + }, + "topic" : { + "string" : "messages", + "objectName" : "message", + "durablePermitted" : true, + "lastMsgRetained" : true + }, + "maxMsgLength" : 1024, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding - wrongly extended.json new file mode 100644 index 00000000..130861da --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding - wrongly extended.json @@ -0,0 +1,22 @@ +{ + "destinationType": "topic", + "queue": { + "objectName": "message", + "isPartitioned": false, + "exclusive": true + }, + "topic": { + "string": "messages", + "objectName": "message", + "durablePermitted": true, + "lastMsgRetained": true + }, + "maxMsgLength": 1024, + "bindingVersion": "latest", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding.json new file mode 100644 index 00000000..e1c8cc11 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/channel/binding.json @@ -0,0 +1,16 @@ +{ + "destinationType": "topic", + "queue": { + "objectName": "message", + "isPartitioned": false, + "exclusive": true + }, + "topic": { + "string": "messages", + "objectName": "message", + "durablePermitted": true, + "lastMsgRetained": true + }, + "maxMsgLength": 1024, + "bindingVersion": "latest" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding - extended.json new file mode 100644 index 00000000..ff8bc475 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding - extended.json @@ -0,0 +1,12 @@ +{ + "bindingVersion" : "0.1.0", + "type" : "jms", + "headers" : "Content-Type: application/json", + "description" : "JMS stream message", + "expiry" : 0, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding - wrongly extended.json new file mode 100644 index 00000000..1574a122 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding - wrongly extended.json @@ -0,0 +1,13 @@ +{ + "type": "jms", + "description": "JMS stream message", + "headers": "Content-Type: application/json", + "expiry": 0, + "bindingVersion": "latest", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding.json new file mode 100644 index 00000000..3a349df2 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/message/binding.json @@ -0,0 +1,7 @@ +{ + "type": "jms", + "description": "JMS stream message", + "headers": "Content-Type: application/json", + "expiry": 0, + "bindingVersion": "latest" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding - extended.json new file mode 100644 index 00000000..32459b79 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding - extended.json @@ -0,0 +1,8 @@ +{ + "bindingVersion" : "0.1.0", + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding - wrongly extended.json new file mode 100644 index 00000000..18560ee8 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding - wrongly extended.json @@ -0,0 +1,9 @@ +{ + "bindingVersion": "latest", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding.json new file mode 100644 index 00000000..cdf165f6 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/operation/binding.json @@ -0,0 +1,3 @@ +{ + "bindingVersion": "latest" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding - extended.json new file mode 100644 index 00000000..ef2ad7e5 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding - extended.json @@ -0,0 +1,13 @@ +{ + "bindingVersion" : "0.1.0", + "groupId" : "PRODCLSTR1", + "ccdtQueueManagerName" : "*", + "cipherSpec" : "ANY_TLS12_OR_HIGHER", + "multiEndpointServer" : false, + "heartBeatInterval" : 300, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding - wrongly extended.json new file mode 100644 index 00000000..2afb5e18 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding - wrongly extended.json @@ -0,0 +1,14 @@ +{ + "groupId": "PRODCLSTR1", + "ccdtQueueManagerName": "*", + "multiEndpointServer": false, + "heartBeatInterval": 300, + "cipherSpec": "ANY_TLS12_OR_HIGHER", + "bindingVersion": "latest", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding.json new file mode 100644 index 00000000..85141cce --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/latest/server/binding.json @@ -0,0 +1,8 @@ +{ + "groupId": "PRODCLSTR1", + "ccdtQueueManagerName": "*", + "multiEndpointServer": false, + "heartBeatInterval": 300, + "cipherSpec": "ANY_TLS12_OR_HIGHER", + "bindingVersion": "latest" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding - extended.json new file mode 100644 index 00000000..f3e6ae31 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding - extended.json @@ -0,0 +1,21 @@ +{ + "bindingVersion" : "0.1.0", + "destinationType" : "topic", + "queue" : { + "objectName" : "message", + "isPartitioned" : false, + "exclusive" : true + }, + "topic" : { + "string" : "messages", + "objectName" : "message", + "durablePermitted" : true, + "lastMsgRetained" : true + }, + "maxMsgLength" : 1024, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding - wrongly extended.json new file mode 100644 index 00000000..bcb60484 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding - wrongly extended.json @@ -0,0 +1,22 @@ +{ + "destinationType": "topic", + "queue": { + "objectName": "message", + "isPartitioned": false, + "exclusive": true + }, + "topic": { + "string": "messages", + "objectName": "message", + "durablePermitted": true, + "lastMsgRetained": true + }, + "maxMsgLength": 1024, + "bindingVersion": "unknown version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding.json new file mode 100644 index 00000000..fc691575 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/channel/binding.json @@ -0,0 +1,16 @@ +{ + "destinationType": "topic", + "queue": { + "objectName": "message", + "isPartitioned": false, + "exclusive": true + }, + "topic": { + "string": "messages", + "objectName": "message", + "durablePermitted": true, + "lastMsgRetained": true + }, + "maxMsgLength": 1024, + "bindingVersion": "unknown version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding - extended.json new file mode 100644 index 00000000..ff8bc475 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding - extended.json @@ -0,0 +1,12 @@ +{ + "bindingVersion" : "0.1.0", + "type" : "jms", + "headers" : "Content-Type: application/json", + "description" : "JMS stream message", + "expiry" : 0, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding - wrongly extended.json new file mode 100644 index 00000000..7c8d3491 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding - wrongly extended.json @@ -0,0 +1,13 @@ +{ + "type": "jms", + "description": "JMS stream message", + "headers": "Content-Type: application/json", + "expiry": 0, + "bindingVersion": "unknown version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding.json new file mode 100644 index 00000000..8d85dd78 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/message/binding.json @@ -0,0 +1,7 @@ +{ + "type": "jms", + "description": "JMS stream message", + "headers": "Content-Type: application/json", + "expiry": 0, + "bindingVersion": "unknown version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding - extended.json new file mode 100644 index 00000000..32459b79 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding - extended.json @@ -0,0 +1,8 @@ +{ + "bindingVersion" : "0.1.0", + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding - wrongly extended.json new file mode 100644 index 00000000..0dee3264 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding - wrongly extended.json @@ -0,0 +1,9 @@ +{ + "bindingVersion": "unknown version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding.json new file mode 100644 index 00000000..defc96bf --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/operation/binding.json @@ -0,0 +1,3 @@ +{ + "bindingVersion": "unknown version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding - extended.json new file mode 100644 index 00000000..ef2ad7e5 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding - extended.json @@ -0,0 +1,13 @@ +{ + "bindingVersion" : "0.1.0", + "groupId" : "PRODCLSTR1", + "ccdtQueueManagerName" : "*", + "cipherSpec" : "ANY_TLS12_OR_HIGHER", + "multiEndpointServer" : false, + "heartBeatInterval" : 300, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding - wrongly extended.json new file mode 100644 index 00000000..f5b67bfa --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding - wrongly extended.json @@ -0,0 +1,14 @@ +{ + "groupId": "PRODCLSTR1", + "ccdtQueueManagerName": "*", + "multiEndpointServer": false, + "heartBeatInterval": 300, + "cipherSpec": "ANY_TLS12_OR_HIGHER", + "bindingVersion": "unknown version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding.json new file mode 100644 index 00000000..fe58c091 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/unknown version/server/binding.json @@ -0,0 +1,8 @@ +{ + "groupId": "PRODCLSTR1", + "ccdtQueueManagerName": "*", + "multiEndpointServer": false, + "heartBeatInterval": 300, + "cipherSpec": "ANY_TLS12_OR_HIGHER", + "bindingVersion": "unknown version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding - extended.json new file mode 100644 index 00000000..f3e6ae31 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding - extended.json @@ -0,0 +1,21 @@ +{ + "bindingVersion" : "0.1.0", + "destinationType" : "topic", + "queue" : { + "objectName" : "message", + "isPartitioned" : false, + "exclusive" : true + }, + "topic" : { + "string" : "messages", + "objectName" : "message", + "durablePermitted" : true, + "lastMsgRetained" : true + }, + "maxMsgLength" : 1024, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding - wrongly extended.json new file mode 100644 index 00000000..fbf1e1c5 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding - wrongly extended.json @@ -0,0 +1,22 @@ +{ + "destinationType": "topic", + "queue": { + "objectName": "message", + "isPartitioned": false, + "exclusive": true + }, + "topic": { + "string": "messages", + "objectName": "message", + "durablePermitted": true, + "lastMsgRetained": true + }, + "maxMsgLength": 1024, + "bindingVersion": "without version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding.json new file mode 100644 index 00000000..ff4c3ce0 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/channel/binding.json @@ -0,0 +1,16 @@ +{ + "destinationType": "topic", + "queue": { + "objectName": "message", + "isPartitioned": false, + "exclusive": true + }, + "topic": { + "string": "messages", + "objectName": "message", + "durablePermitted": true, + "lastMsgRetained": true + }, + "maxMsgLength": 1024, + "bindingVersion": "without version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding - extended.json new file mode 100644 index 00000000..ff8bc475 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding - extended.json @@ -0,0 +1,12 @@ +{ + "bindingVersion" : "0.1.0", + "type" : "jms", + "headers" : "Content-Type: application/json", + "description" : "JMS stream message", + "expiry" : 0, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding - wrongly extended.json new file mode 100644 index 00000000..2029f4ba --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding - wrongly extended.json @@ -0,0 +1,13 @@ +{ + "type": "jms", + "description": "JMS stream message", + "headers": "Content-Type: application/json", + "expiry": 0, + "bindingVersion": "without version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding.json new file mode 100644 index 00000000..c57f07b2 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/message/binding.json @@ -0,0 +1,7 @@ +{ + "type": "jms", + "description": "JMS stream message", + "headers": "Content-Type: application/json", + "expiry": 0, + "bindingVersion": "without version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding - extended.json new file mode 100644 index 00000000..32459b79 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding - extended.json @@ -0,0 +1,8 @@ +{ + "bindingVersion" : "0.1.0", + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding - wrongly extended.json new file mode 100644 index 00000000..7365f2b2 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding - wrongly extended.json @@ -0,0 +1,9 @@ +{ + "bindingVersion": "without version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding.json new file mode 100644 index 00000000..0c27f736 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/operation/binding.json @@ -0,0 +1,3 @@ +{ + "bindingVersion": "without version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding - extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding - extended.json new file mode 100644 index 00000000..ef2ad7e5 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding - extended.json @@ -0,0 +1,13 @@ +{ + "bindingVersion" : "0.1.0", + "groupId" : "PRODCLSTR1", + "ccdtQueueManagerName" : "*", + "cipherSpec" : "ANY_TLS12_OR_HIGHER", + "multiEndpointServer" : false, + "heartBeatInterval" : 300, + "x-number" : 0, + "x-string" : "", + "x-object" : { + "property" : { } + } +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding - wrongly extended.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding - wrongly extended.json new file mode 100644 index 00000000..aa92ec23 --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding - wrongly extended.json @@ -0,0 +1,14 @@ +{ + "groupId": "PRODCLSTR1", + "ccdtQueueManagerName": "*", + "multiEndpointServer": false, + "heartBeatInterval": 300, + "cipherSpec": "ANY_TLS12_OR_HIGHER", + "bindingVersion": "without version", + "x-number": 0, + "x-string": "", + "x-object": { + "property": {} + }, + "ext-number": 1 +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding.json b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding.json new file mode 100644 index 00000000..155437bd --- /dev/null +++ b/asyncapi-core/src/test/resources/bindings/ibmmq/without version/server/binding.json @@ -0,0 +1,8 @@ +{ + "groupId": "PRODCLSTR1", + "ccdtQueueManagerName": "*", + "multiEndpointServer": false, + "heartBeatInterval": 300, + "cipherSpec": "ANY_TLS12_OR_HIGHER", + "bindingVersion": "without version" +} \ No newline at end of file diff --git a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/asyncapi - extended.json b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/asyncapi - extended.json index 0c78a705..ee7fb107 100644 --- a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/asyncapi - extended.json +++ b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/asyncapi - extended.json @@ -161,7 +161,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -279,7 +281,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -400,7 +404,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -518,7 +524,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -1200,7 +1208,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -1619,7 +1629,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", diff --git a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/channelItem - extended.json b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/channelItem - extended.json index cdf89275..0234925e 100644 --- a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/channelItem - extended.json +++ b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/channelItem - extended.json @@ -55,7 +55,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -173,7 +175,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -294,7 +298,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -412,7 +418,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", diff --git a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with message - extended.json b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with message - extended.json index a17fc37f..3bbef16a 100644 --- a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with message - extended.json +++ b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with message - extended.json @@ -53,7 +53,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -171,7 +173,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", diff --git a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with reference to message - extended.json b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with reference to message - extended.json index d057ad7b..fe6224be 100644 --- a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with reference to message - extended.json +++ b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operation with reference to message - extended.json @@ -53,7 +53,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -171,7 +173,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", diff --git a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operationTrait - extended.json b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operationTrait - extended.json index 82f865dd..5d34607b 100644 --- a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operationTrait - extended.json +++ b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/channel/operation/operationTrait - extended.json @@ -53,7 +53,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", diff --git a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/components/components - extended.json b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/components/components - extended.json index 31549965..2e89b083 100644 --- a/asyncapi-core/src/test/resources/json/v2/2.0.0/model/components/components - extended.json +++ b/asyncapi-core/src/test/resources/json/v2/2.0.0/model/components/components - extended.json @@ -342,7 +342,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0", @@ -761,7 +763,9 @@ "additionalProperties" : false } }, - "ibmmq" : { }, + "ibmmq" : { + "bindingVersion" : "0.1.0" + }, "jms" : { }, "kafka" : { "bindingVersion" : "0.4.0",