(PECL mqseries >= 0.10.0)
mqseries_put — MQSeries MQPUT
函数 mqseries_put() (MQPUT) 将消息放入队列或分发列表。队列或分发列表必须已经打开。
hConn
连接句柄。
此句柄表示与队列管理器的连接。
hObj
对象句柄。
此句柄表示要使用的对象。
md
消息描述符 (MQMD)。
pmo
放置消息选项 (MQPMO)。
message
要放入队列的实际消息。
compCode
完成代码。
reason
限定 compCode 的原因代码。
不返回值。
范例 #1 mqseries_put() 范例
<?php
// 打开与队列管理器的连接
mqseries_conn('WMQ1', $conn, $comp_code, $reason);
// $conn 现在保存了与队列管理器的连接的引用。
// 打开与 testq 队列的连接
mqseries_open(
$conn,
array('ObjectName' => 'TESTQ'),
MQSERIES_MQOO_INPUT_AS_Q_DEF | MQSERIES_MQOO_FAIL_IF_QUIESCING | MQSERIES_MQOO_OUTPUT,
$obj,
$comp_code,
$reason);
// $obj 现在保存了对象 (TESTQ) 的引用
// 设置消息描述符数组。查看 MQSeries 参考手册。
$md = array(
'Version' => MQSERIES_MQMD_VERSION_1,
'Expiry' => MQSERIES_MQEI_UNLIMITED,
'Report' => MQSERIES_MQRO_NONE,
'MsgType' => MQSERIES_MQMT_DATAGRAM,
'Format' => MQSERIES_MQFMT_STRING,
'Priority' => 1,
'Persistence' => MQSERIES_MQPER_PERSISTENT);
// 设置放置消息选项。
$pmo = array('Options' => MQSERIES_MQPMO_NEW_MSG_ID|MQSERIES_MQPMO_SYNCPOINT);
// 将消息 'Ping' 放入队列。
mqseries_put($conn, $obj, $md, $pmo, 'Ping', $comp_code, $reason);
if ($comp_code !== MQSERIES_MQCC_OK) {
printf("put CompCode:%d Reason:%d Text:%s<br>\n", $comp_code, $reason, mqseries_strerror($reason));
}
// 关闭对象引用 $obj
mqseries_close($conn, $obj, MQSERIES_MQCO_NONE, $comp_code, $reason);
// 断开与队列管理器的连接。
mqseries_disc($conn, $comp_code, $reason);
?>