- 论坛徽章:
- 0
|
memcpy(odG.ObjectName, /* name of input queue */
trig -> QName, MQ_Q_NAME_LENGTH);
O_options = MQOO_INPUT_SHARED /* open queue for shared input */
+ MQOO_FAIL_IF_QUIESCING; /* but not if MQM stopping */
MQOPEN(Hcon, /* connection handle */
&odG, /* object descriptor for queue */
O_options, /* open options */
&Hobj_g, /* object handle */
&CompCode, /* MQOPEN completion code */
&Reason); /* reason code */
/* report reason if any; stop if it failed */
if (Reason != MQRC_NONE)
{
printf("MQOPEN (input) ended with reason code %ld\n", Reason);
}
if (CompCode == MQCC_FAILED)
{
exit(Reason);
} |
|