Здравствуйте.
Помогите создать 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();
В инете мало информации на этот счет. Кто-нибудь имел с этим дело?
Буду признателен, если покажете пример.
Заранее спасибо.