WebSphere MQ: Trigging->Trigger Monitor. Как?
От: N_i_t_r_o  
Дата: 06.03.08 09:40
Оценка:
Здравствуйте.

Помогите создать Trigger Monitor в схеме наподобие этой http://publib.boulder.ibm.com/infocenter/wmqv6/v6r0/topic/com.ibm.mq.csqzal.doc/fg13840_.htm (первый рисунок).
Я не могу создать Initiation Queue (средствами MQ API, пишется все на J2SE).

Для теста написал следующее...
            Hashtable htProperty = new Hashtable();
            htProperty.put(MQC.HOST_NAME_PROPERTY, mqhost);
            htProperty.put(MQC.CHANNEL_PROPERTY, mqchannel);
            htProperty.put(MQC.PORT_PROPERTY, new mqport);
            htProperty.put(MQC.USER_ID_PROPERTY, userid);
            MQQueueManager qMgr = new MQQueueManager(mqmanager, htProperty);
            
            MQQueue initQueue = ??? // Как создать Initiation Queue??? 
            initQueue.setTriggerControl(MQC.MQTC_ON);  // Вкл. триггер
            initQueue.setTriggerType(MQC.MQTT_FIRST);  // Тип триггера
                    
            // put message
            MQQueue queue = qMgr.accessQueue(mqqueue, MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT);
            MQMessage message = new MQMessage();
            message.writeString(msg.getMessage());
            MQPutMessageOptions pmo = new MQPutMessageOptions(); 
            queue.put(message, pmo);
            
            // get message from Initiation Queue
            String s = initQueue.getTriggerData();
            System.out.println(s);
            
            // get message
            MQMessage retrievedMessage = new MQMessage();
            MQGetMessageOptions gmo = new MQGetMessageOptions(); 
            queue.get(retrievedMessage, gmo);
            
            queue.close();
            retrievedMessage.close();
            qMgr.disconnect();




В инете мало информации на этот счет. Кто-нибудь имел с этим дело?
Буду признателен, если покажете пример.
Заранее спасибо.
 
Подождите ...
Wait...
Пока на собственное сообщение не было ответов, его можно удалить.