Added tests for JmsPut and JmsGet

JMS/README.md

@@ -367,7 +367,9 @@ By default these samples will run in client mode. If you do want to run the samp
 to the `env.json` file.
 
 ## Unit Test
-The samples also contain unit tests in `src/test` , which you can run using maven with the following command :
+The samples also contain unit tests in `src/test`. These tests require connection with a Queue Manager and use the default `env.json` present in the repository, hence make sure you have atleast one valid endpoint in the `env.json`.
+
+To run these tests, Use the following command:
 
 ````
 mvn test

JMS/src/test/java/com/ibm/mq/samples/jms/JmsGetTest.java

@@ -0,0 +1,53 @@
+/*
+* (c) Copyright IBM Corporation 2024
+*
+* Licensed 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.
+*/
+
+package com.ibm.mq.samples.jms;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import java.util.Enumeration;
+
+import javax.jms.JMSContext;
+import javax.jms.JMSException;
+import javax.jms.Queue;
+import javax.jms.QueueBrowser;
+
+import org.junit.jupiter.api.Test;
+
+public class JmsGetTest {
+    private JMSContext context = null;
+    private Queue destination = null;
+    private QueueBrowser browser = null;
+    private ConnectionHelper ch = null;
+    @Test
+    public void testJmsGet(){
+        JmsPut.main(null);
+        JmsGet.main(null);
+
+        ch = new ConnectionHelper("Basic Get", 0);
+        context = ch.getContext();
+        destination = (Queue)ch.getDestination();
+        browser = context.createBrowser(destination);
+        try {
+            Enumeration<?> messages = browser.getEnumeration();
+            assertFalse(messages.hasMoreElements());
+        } catch (JMSException jmsex) {
+            jmsex.printStackTrace();
+        }
+        ch.closeContext();;
+    }
+
+}

JMS/src/test/java/com/ibm/mq/samples/jms/JmsPutTest.java

@@ -0,0 +1,131 @@
+/*
+* (c) Copyright IBM Corporation 2024
+*
+* Licensed 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.
+*/
+
+package com.ibm.mq.samples.jms;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import javax.jms.JMSConsumer;
+import javax.jms.JMSContext;
+import javax.jms.JMSException;
+import javax.jms.Destination;
+import javax.jms.Message;
+import javax.jms.TextMessage;
+import javax.jms.JMSRuntimeException;
+
+import org.junit.jupiter.api.Test;
+
+import com.ibm.mq.MQException;
+import com.ibm.mq.constants.MQConstants;
+
+
+public class JmsPutTest {
+    private JMSContext context = null;
+    private Destination destination = null;
+    private JMSConsumer consumer = null;
+    private ConnectionHelper ch = null;
+    private static long TIMEOUTTIME = 5000;
+    @Test
+    public void testJmsPut(){
+        clearQueue();
+        JmsPut.main(null);
+
+        ch = new ConnectionHelper("Basic Get", 0);
+        context = ch.getContext();
+        destination = ch.getDestination();
+        consumer = context.createConsumer(destination);
+        for(int i = 1 ; i <= 10 ; i++){
+            try {
+                Message recievedMessage = consumer.receive(TIMEOUTTIME);
+                String value = "This is message number " + i + ".";
+                String message = getMessageBody(recievedMessage);
+                assertEquals(value, message);
+                waitAWhile(1000);
+            } catch (JMSRuntimeException jmsex) {
+                jmsex.printStackTrace();
+                waitAWhile(1000);
+            }
+        }
+        ch.closeContext();
+    }
+
+
+    @Test
+    public void testIncorrectQM(){ 
+        System.setProperty("QMGR", "INVALID_QM");
+        JMSRuntimeException jmsex = assertThrows(JMSRuntimeException.class , () -> {
+            JmsPut.main(null);
+        });
+
+        MQException inException = (MQException) jmsex.getCause();
+        assertEquals(MQConstants.MQRC_Q_MGR_NAME_ERROR, inException.getReason());
+        System.clearProperty("QMGR");
+    }
+
+    @Test
+    public void testIncorrectQueue(){
+        System.setProperty("QUEUE_NAME" , "INVALID_QUEUE");
+        JMSRuntimeException jmsex = assertThrows(JMSRuntimeException.class, () -> {
+            JmsPut.main(null);
+        });
+
+        MQException inException = (MQException) jmsex.getCause();
+        assertEquals(MQConstants.MQRC_UNKNOWN_OBJECT_NAME, inException.getReason());
+        System.clearProperty("QUEUE_NAME");
+    }
+
+    @Test
+    public void testIncorrectChannel(){
+        System.setProperty("CHANNEL" , "INCORRECT_CHANNEL");
+        JMSRuntimeException jmsex = assertThrows(JMSRuntimeException.class, () -> {
+            JmsPut.main(null);
+        });
+        MQException inException = (MQException) jmsex.getCause();
+        assertEquals(MQConstants.MQRC_UNKNOWN_CHANNEL_NAME, inException.getReason());
+        System.clearProperty("CHANNEL");
+    }
+
+
+    private void clearQueue(){
+        BasicConsumer bc = new BasicConsumer(BasicConsumer.CONSUMER_GET, 0);
+        bc.receive(1000);
+        bc.close();
+    }
+
+    private static String getMessageBody(Message receivedMessage) {
+        if (receivedMessage instanceof TextMessage) {
+            TextMessage textMessage = (TextMessage) receivedMessage;
+            try {
+                return textMessage.getText();
+            } catch (JMSException jmsex) {
+                return "Error getting a message";
+            }
+        } else if (receivedMessage instanceof Message) {
+            return "Message received was not of type TextMessage.";
+        } else {
+            return "Received object not of JMS Message type!";
+        }
+    }
+
+    private static void waitAWhile(int duration) {
+        try {
+            Thread.sleep(duration);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+}