SoapUI : Websphere MQ Test Integration with Groovy

MQ Injection and reception of messages using groovy is rather easy than setting up with HermesJMS and far more stable.

Below is a simple example :

  import com.ibm.msg.client.wmq.*; import com.ibm.mq.jms.*; import javax.jms.*; // Initialize connection variables def mq_ip = context.expand('${#Project#mq_ip}') int mq_port = context.expand('${#Project#mq_port}') as Integer def mq_user = context.expand('${#Project#mq_user}') def mq_pass = context.expand('${#Project#mq_pass}') def mq_qmgr = context.expand('${#Project#mq_qmgr}') def mq_in_q = context.expand('${#Project#mq_in_q}') def mq_out_q = context.expand('${#Project#mq_out_q}') // Get XML Request from the previous Step //testRunner.testCase.testSteps["Order 1"].testRequest.response.getRequestContent() MQQueueConnectionFactory qcf = new MQQueueConnectionFactory(); // Host and port settings qcf.setHostName (mq_ip); qcf.setPort (mq_port); // Queue manager and channel — the W-MQ administrator should supply these qcf.setQueueManager (mq_qmgr); qcf.setChannel ("SYSTEM.ADMIN.SVRCONN"); // Although there are many possible values of transport type, // only 'client' and 'bindings' work in a Java client. Bindings // is a kind of in-memory transport and only works when the client // and the queue manager are on the same physical host. In most // cases, we need 'client'. //qcf.setTransportType (WMQConstants.WMQ_CM_BINDINGS); qcf .setTransportType (WMQConstants.WMQ_CM_CLIENT); QueueConnection qc = qcf.createQueueConnection (mq_user,mq_pass); //set credentials // QueueConnection qc = qcf.createQueueConnection (); // if authenticaiton is disabled qc.start(); // Create a queue and a session Queue in = new MQQueue (mq_in_q); Queue out = new MQQueue (mq_out_q); QueueSession s = qc.createQueueSession (false, Session.AUTO_ACKNOWLEDGE); // Create and send a TextMessage QueueSender qs = s.createSender (in); Message m = s.createTextMessage ("Your message text"); qs.send (m); qs.close(); // Receive a TextMessage QueueReceiver qr = s.createReceiver(out); TextMessage message = (TextMessage) qr.receive(); log.info message.getText() qr.close() // Stop and close Connection qc.stop(); qc.close();

While integrating with maven, you will have to ensure that you have included the following dependencies in your pom file.

<dependencies> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>com.ibm.jms</artifactId> <version>8.0.0.3</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>com.ibm.mq.allclient</artifactId> <version>8.0.0.5</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>com.ibm.mq.jmqi</artifactId> <version>7.1.0.1</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>com.ibm.mq</artifactId> <version>7.1.0.1</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>com.ibm.mqbind</artifactId> <version>5.3</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>com.ibm.mqjms</artifactId> <version>7.1.0.1</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>dhbcore</artifactId> <version>7.1.0.1</version> </dependency> <dependency> <groupid>com.ibm.mq</groupId> <artifactid>mqconnector</artifactId> <version>6.0.2.4</version> </dependency> </dependencies>