tilln
commented
7 months ago Hi @mehrdad2000
You have to write your own Channel Class that wraps the JMS objects.
It would have to implement ISOChannel to be able to connect, send, receive etc. via JMS queue.
It should implement Configurable so you can pass in required properties via the test plan, for example:
Below is an example of how you would access those properties.
You would also have to convert the ISOMsg that the ISO8583 Sampler generates into an appropriate JMS message, see below for an example.
public class JMSChannel implements ISOChannel, Configurable {
MQQueueConnectionFactory cf;
// etc., your other JMS objects
public void setConfiguration(Configuration cfg) throws ConfigurationException {
// From common "Channel Settings":
cf.setHostName(cfg.get("host"));
cf.setPort(cfg.getInt("port"));
// From "Advanced Configuration":
cf.setQueueManager(cfg.get("queueManager"));
cf.setChannel(cfg.get("channel"));
// etc., your other config properties
}
public void send(ISOMsg isoMsg) throws IOException, ISOException {
// Assuming your messages are sent as bytes rather than text:
BytesMessage jmsMsg = session.createBytesMessage();
jmsMsg.writeBytes(isoMsg.pack());
sender.send(jmsMsg);
}
// etc., other methods
}Most other ISOChannels extend BaseChannel for sending messages via all sorts of network/TCP connections, so you may want to have a look at how that is done.
I hope this gives you some ideas and a starting point.
mehrdad2000
github-actions[bot]
I try to send message from jmeter-iso8583 to mq, but it’s not work.
here is the my current JSR223 sampler that work correctly and send “mymessage“ to mq, now question is how can i send output of iso8583 plugin to mq server? Is it possible to add “queue manager, channel, user, pass, queue name,…) in connection manager of jmeter-iso8583?
import com.ibm.jms.JMSTextMessage; import com.ibm.mq.jms.*; import com.ibm.msg.client.wmq.WMQConstants;
import javax.jms.JMSException; import javax.jms.Session;
MQQueueConnectionFactory cf = new MQQueueConnectionFactory(); cf.setHostName("192.168.1.1"); cf.setPort(1443); // or other port cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT); cf.setQueueManager("qm"); cf.setChannel("my.SVRCONN"); cf.setStringProperty(WMQConstants.USERID, "user"); cf.setStringProperty(WMQConstants.PASSWORD, "pass"); connection = (MQQueueConnection) cf.createQueueConnection(); MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); MQQueue queue = (MQQueue) session.createQueue("queue:///my.queue"); MQQueueSender sender = (MQQueueSender) session.createSender(queue); JMSTextMessage message = (JMSTextMessage) session.createTextMessage("mymessage"); connection.start(); sender.send(message);