mqseries_put

(PECL mqseries >= 0.10.0)

mqseries_putMQSeries MQPUT

Описание

mqseries_put ( resource $hConn , resource $hObj , array &$md , array &$pmo , string $message , resource &$compCode , resource &$reason ) : void

Функция mqseries_put() (MQPUT) помещает сообщение в очередь или список распределения. Очередь, или список распределения, должна быть открыты.

Список параметров

hConn

Обработчик соединения.

Представляет открытое соединение с менеджером очередей.

hObj

Обработчик объекта.

Представляет используемый объект.

md

Дескриптор сообщения (MQMD).

pmo

Опции добавляемого сообщения (MQPMO).

message

Само сообщение.

compCode

Код завершения.

reason

Код причины, квалифицирующий compCode.

Возвращаемые значения

Эта функция не возвращает значения после выполнения.

Примеры

Пример #1 Пример использования mqseries_put()

<?php
// Открываем соединение с MQ
    
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$reasonmqseries_strerror($reason));
    }

// Закрываем обработчик объекта $obj    
    
mqseries_close($conn$objMQSERIES_MQCO_NONE$comp_code$reason);

// Закрываем соединение с менеджером.
    
mqseries_disc($conn$comp_code$reason);
    
?>

Смотрите также

add a note add a note

User Contributed Notes

There are no user contributed notes for this page.
To Top