...
For each collected message, the IBM MQ collection agent sends an InputMessage including an MQMessage UDR to the Analysis agent. If "Auto Remove" has been configured, the message is removed from the queue and a remMessage is sent to the agent.
Realtime workflow example - a message is collected from the IBM MQ collection agent
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
mq.MQQueue queue;
initialize {
mq.MQQueueManagerInfo conUDR = udrCreate(mq.MQQueueManagerInfo);
conUDR.ChannelName = "CHANNEL1";
conUDR.Host = "10.46.100.86";
conUDR.Port = 1414;
conUDR.QueueManager = "mgr1.queue.manager";
queue = mqConnect(conUDR, "Q1.QUEUE");
}
consume {
mqStatus(queue);
debug("Queue Depth: "+queue.CurrentDepth);
debug("Queue Max Depth: "+queue.MaxDepth);
mq.MQMessage msg = udrCreate(mq.MQMessage);
msg.Message = input;
mqPut(queue, msg);
}
deinitialize {
mqClose(queue);
} |
| Scroll ignore | ||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| ||||||||||||||||
| Scroll pagebreak |
|---|