1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40
| import com.ibm.mq.*;
public class MQPUT
{
private static final String qManager = "QM_serv";
private static final String qName = "Q1";
public static void main(String args[])
{
new MQPUT().runSample();
}
public void runSample()
{
try
{
MQEnvironment.hostname = "192.168.0.1";
MQEnvironment.channel = "serv";
MQEnvironment.port = Integer.parseInt("1421");
MQQueueManager qMgr = new MQQueueManager(qManager);
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
MQQueue queue = qMgr.accessQueue(qName, openOptions);
MQMessage msg = new MQMessage();
msg.writeString("TESTING MESSAGE" + System.currentTimeMillis());
MQPutMessageOptions pmo = new MQPutMessageOptions();
queue.put(msg, pmo);
queue.close();
qMgr.disconnect();
System.out.println("Message Sent!");
}
catch (MQException ex)
{
System.out.println("An Error occured : Completion Code " + ex.completionCode + " Reason Code " + ex.reasonCode);
}
catch (java.io.IOException ex)
{
System.out.println("Exception Occured:" + ex);
}
}
} |
Partager