Forum Discussion

Daviiid's avatar
Daviiid
New Contributor
10 years ago

[Resolved] jms get message on CorrelId

Hello I configured soapUi to send/receive message on JMS MQ queue. Here is my url jms://DAVID::queue_REQ::queue_REP It's nice except i always get thefirst message in the response Mq Queue (and it's...
Daviiid's avatar
Daviiid
New Contributor
10 years ago
Hi
I wrote a groovy script for put and get on correlationId after copying mq jar files into the file ${SoapUiRep}/lib/ext

import com.ibm.mq.*
/* definition de la connexion au QManager */

MQEnvironment.@hostname = "host"
MQEnvironment.@port = 1414
MQEnvironment.@channel = "CHANNEL.NAME"
MQEnvironment.@userID  = "jmsmq"
MQEnvironment.disableTracing();
def queueManager = new MQQueueManager('QueueManagerName')
def putMsg = new MQMessage();


/* option du header MQMD */
putMsg.setVersion(MQC.MQMD_VERSION_2);
putMsg.format = MQC.MQFMT_STRING;
putMsg.characterSet  = 1208

/* Message à déposer  */
putMsg.writeString('String Message');

/* dénition file d'attente request avec option et dépose */
def putQ = queueManager.accessQueue('NomQueueRequest', MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING);
putQ.put(putMsg, new MQPutMessageOptions());
putQ.close()


/* definition  des options de get */
MQGetMessageOptions getOptions = new MQGetMessageOptions();
getOptions.options = MQC.MQGMO_WAIT + MQC.MQGMO_FAIL_IF_QUIESCING;
getOptions.waitInterval = 15000;//MQC.MQWI_UNLIMITED;

/* definition du corrleId a getter */
def message = new MQMessage();
message.correlationId = putMsg.messageId;

/* definition de la queue a getter en y mettant les option */
def MQQueue getQ;
getQ = queueManager.accessQueue('NomQueueResponse', getOptions.options);
getQ.get(message, getOptions);
def response = message.readString(message.getMessageLength())
getQ.close()
log.info response