forked from ballerina-platform/module-ballerinax-ibm.ibmmq
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
7 changed files
with
287 additions
and
56 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,196 @@ | ||
| // Copyright (c) 2023, WSO2 LLC. (http://www.wso2.org) All Rights Reserved. | ||
| // | ||
| // WSO2 LLC. licenses this file to you under the Apache License, | ||
| // Version 2.0 (the "License"); you may not use this file except | ||
| // in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, | ||
| // software distributed under the License is distributed on an | ||
| // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | ||
| // KIND, either express or implied. See the License for the | ||
| // specific language governing permissions and limitations | ||
| // under the License. | ||
| import ballerina/test; | ||
|
|
||
| @test:Config {} | ||
| function basicPublisherSubscriberTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic subscriber = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_SUBSCRIPTION, MQSO_CREATE); | ||
| Topic publisher = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| check publisher->put({ | ||
| payload: "Hello World".toBytes() | ||
| }); | ||
| Message? message = check subscriber->get(); | ||
| if message !is () { | ||
| test:assertEquals(string:fromBytes(message.payload), "Hello World"); | ||
| } else { | ||
| test:assertFail("Expected a value for message"); | ||
| } | ||
| check subscriber->close(); | ||
| check publisher->close(); | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function pubSubMultipleMessagesInOrderTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic subscriber = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_SUBSCRIPTION, MQSO_CREATE); | ||
| Topic publisher = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| foreach int i in 0 ... 4 { | ||
| check publisher->put({ | ||
| payload: i.toString().toBytes() | ||
| }); | ||
| } | ||
| foreach int i in 0 ... 4 { | ||
| Message? message = check subscriber->get(waitInterval = 2); | ||
| if message !is () { | ||
| test:assertEquals(string:fromBytes(message.payload), i.toString()); | ||
| } else { | ||
| test:assertFail("Expected a value for message"); | ||
| } | ||
| } | ||
| check subscriber->close(); | ||
| check publisher->close(); | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function subscribeWithFiniteTimeoutTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic subscriber = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_SUBSCRIPTION, MQSO_CREATE); | ||
| Topic publisher = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| check publisher->put({ | ||
| payload: "Hello World".toBytes() | ||
| }); | ||
| Message? message = check subscriber->get(waitInterval = 5); | ||
| if message !is () { | ||
| test:assertEquals(string:fromBytes(message.payload), "Hello World"); | ||
| } else { | ||
| test:assertFail("Expected a value for message"); | ||
| } | ||
| check subscriber->close(); | ||
| check publisher->close(); | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function subscribeWithoutPublishTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic subscriber = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_SUBSCRIPTION, MQSO_CREATE); | ||
| Message|Error? result = subscriber->get(waitInterval = 5); | ||
| test:assertTrue(result is ()); | ||
| check subscriber->close(); | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function publishToNonExistingTopicTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic|Error result = queueManager.accessTopic("dev", "NON.EXISTING.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while accessing topic: MQJE001: Completion Code '2', Reason '2085'."); | ||
| test:assertEquals(result.detail().reasonCode, 2085); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function subscribeToNonExistingTopicTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic|Error result = queueManager.accessTopic("dev", "NON.EXISTING.TOPIC", OPEN_AS_SUBSCRIPTION, MQSO_CREATE); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while accessing topic: MQJE001: Completion Code '2', Reason '2085'."); | ||
| test:assertEquals(result.detail().reasonCode, 2085); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function subscribeWithInvalidTopicNameTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic|Error result = queueManager.accessTopic("dev", "INVALID TOPIC", OPEN_AS_SUBSCRIPTION, MQSO_CREATE); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while accessing topic: MQJE001: Completion Code '2', Reason '2152'."); | ||
| test:assertEquals(result.detail().reasonCode, 2152); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function publishWithInvalidTopicNameTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic|Error result = queueManager.accessTopic("dev", "INVALID TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while accessing topic: MQJE001: Completion Code '2', Reason '2085'."); | ||
| test:assertEquals(result.detail().reasonCode, 2085); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function accessTopicAfterQMDisconnectTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| check queueManager.disconnect(); | ||
| Topic|Error result = queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while accessing topic: MQJE001: An MQException " + | ||
| "occurred: Completion Code '2', Reason '2018'\n'MQJI002: Not connected to a queue manager.'."); | ||
| test:assertEquals(result.detail().reasonCode, 2018); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function putToTopicAfterTopicCloseTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic publisher = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| check publisher->close(); | ||
| Error? result = publisher->put({ | ||
| payload: "Hello World".toBytes() | ||
| }); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while putting a message to the topic: MQJE001: " + | ||
| "An MQException occurred: Completion Code '2', Reason '2019'\n'MQJI027: The queue has been closed.'."); | ||
| test:assertEquals(result.detail().reasonCode, 2019); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| check queueManager.disconnect(); | ||
| } | ||
|
|
||
| @test:Config {} | ||
| function putToTopicAfterQMDisconnectTest() returns error? { | ||
| QueueManager queueManager = check new QueueManager(name = "QM1", host = "localhost", channel = "DEV.APP.SVRCONN"); | ||
| Topic publisher = check queueManager.accessTopic("dev", "DEV.BASE.TOPIC", OPEN_AS_PUBLICATION, MQOO_OUTPUT); | ||
| check queueManager.disconnect(); | ||
| Error? result = publisher->put({ | ||
| payload: "Hello World".toBytes() | ||
| }); | ||
| if result is Error { | ||
| test:assertEquals(result.message(), "Error occurred while putting a message to the topic: MQJE001: An MQException " + | ||
| "occurred: Completion Code '2', Reason '2018'\n'MQJI002: Not connected to a queue manager.'."); | ||
| test:assertEquals(result.detail().reasonCode, 2018); | ||
| test:assertEquals(result.detail().completionCode, 2); | ||
| } else { | ||
| test:assertFail("Expected an error"); | ||
| } | ||
| check queueManager.disconnect(); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| version: "3.9" | ||
|
|
||
| services: | ||
| mq: | ||
| image: icr.io/ibm-messaging/mq:latest | ||
| container_name: ibmmq-test | ||
| ports: | ||
| - "1414:1414" | ||
| - "9443:9443" | ||
| environment: | ||
| - LICENSE=accept | ||
| - MQ_QMGR_NAME=QM1 |
Oops, something went wrong.