| |
|
RSS Feed - WebSphere MQ Support
|
RSS Feed - Message Broker Support
|
  |
|
| Event MsgFlow data (Events) inserted into DB |
« View previous topic :: View next topic » |
| Author |
Message
|
| MB Developer |
 Posted: Mon Apr 06, 2015 11:06 am Post subject: Event MsgFlow data (Events) inserted into DB |
 |
|
Disciple
Joined: 03 Feb 2014
Posts: 179
|
Hi Experts,
Greetings....
I create a Message Flow with MQInput --> Compute --> MQOutput Nodes
Assign the Monitoring Events (QIN.FailureTerminal and QIN.CatchTerminal) to MQInput Node.
--> Then .msgflow file is
| Code: |
<?xml version="1.0" encoding="UTF-8"?>
<ecore:EPackage xmi:version="2.0"
xmlns:xmi="http://www.omg.org/XMI" xmlns:ComIbmCompute.msgnode="ComIbmCompute.msgnode" xmlns:ComIbmMQInput.msgnode="ComIbmMQInput.msgnode" xmlns:ComIbmMQOutput.msgnode="ComIbmMQOutput.msgnode" xmlns:ComIbmTrace.msgnode="ComIbmTrace.msgnode" xmlns:ecore="http://www.eclipse.org/emf/2002/Ecore" xmlns:eflow="http://www.ibm.com/wbi/2005/eflow" xmlns:mbmonitor="http://www.ibm.com/wbi/2008/eflow_mbmonitor" xmlns:utility="http://www.ibm.com/wbi/2005/eflow_utility" nsURI="MonitoringEvents_MF.msgflow"
nsPrefix="MonitoringEvents_MF.msgflow">
<eClassifiers xmi:type="eflow:FCMComposite" name="FCMComposite_1">
<eSuperTypes href="http://www.ibm.com/wbi/2005/eflow#//FCMBlock"/>
<translation xmi:type="utility:TranslatableString" key="MonitoringEvents_MF" bundleName="MonitoringEvents_MF" pluginId="MonitoringEvents_MFP"/>
<colorGraphic16 xmi:type="utility:GIFFileGraphic" resourceName="platform:/plugin/MonitoringEvents_MFP/icons/full/obj16/MonitoringEvents_MF.gif"/>
<colorGraphic32 xmi:type="utility:GIFFileGraphic" resourceName="platform:/plugin/MonitoringEvents_MFP/icons/full/obj30/MonitoringEvents_MF.gif"/>
<composition>
<nodes xmi:type="ComIbmMQInput.msgnode:FCMComposite_1" xmi:id="FCMComposite_1_1" location="56,112" queueName="QIN" messageDomainProperty="MRM" messageSetProperty="TempConvMsg_MS" messageTypeProperty="{}:TemperatureConversion" messageFormatProperty="XML1">
<translation xmi:type="utility:ConstantString" string="QIN"/>
<monitorEvents eventSourceDescription="Failure terminal" eventSourceName="QIN.terminal.failure" eventIdentity="QIN.FailureTerminal">
<eventXMLDoc xmi:type="mbmonitor:MonitorEvent">
<applicationData dataLocation="$ExceptionList" isXPath="true" complexData="true"/>
<globalTransactionCorrelator/>
<parentTransactionCorrelator/>
<localTransactionCorrelator/>
<bitStreamData encoding="CDATA" bitstreamContent="body"/>
<eventName literal="QIN.FailureTerminal"/>
<eventFilter dataLocation="true()" isXPath="true"/>
</eventXMLDoc>
</monitorEvents>
<monitorEvents eventSourceDescription="Catch terminal" eventSourceName="QIN.terminal.catch" eventIdentity="QIN.CatchTerminal">
<eventXMLDoc xmi:type="mbmonitor:MonitorEvent">
<applicationData dataLocation="$ExceptionList" isXPath="true" complexData="true"/>
<globalTransactionCorrelator/>
<parentTransactionCorrelator/>
<localTransactionCorrelator/>
<bitStreamData encoding="CDATA" bitstreamContent="body"/>
<eventName literal="QIN.CatchTerminal"/>
<eventFilter dataLocation="true()" isXPath="true"/>
</eventXMLDoc>
</monitorEvents>
</nodes>
<nodes xmi:type="ComIbmCompute.msgnode:FCMComposite_1" xmi:id="FCMComposite_1_2" location="226,196" dataSource="DbError" computeExpression="esql://routine/#MonitoringEvents_MF_Build_HTTP_Request_Msg.Main">
<translation xmi:type="utility:ConstantString" string="Build_HTTP_Request_Msg"/>
</nodes>
<nodes xmi:type="ComIbmMQOutput.msgnode:FCMComposite_1" xmi:id="FCMComposite_1_5" location="502,104" queueName="QOUT">
<translation xmi:type="utility:ConstantString" string="QOUT"/>
</nodes>
<nodes xmi:type="ComIbmTrace.msgnode:FCMComposite_1" xmi:id="FCMComposite_1_7" location="163,23" destination="file" filePath="D:\Balaji\Event Monitoring\Trace.txt" pattern="CurrentTime:${CURRENT_TIMESTAMP}
ExceptionList:${ExceptionList}
-------------------------------------------------------------------------------------------------------------------------------------------------------------">
<translation xmi:type="utility:ConstantString" string="Trace"/>
</nodes>
<connections xmi:type="eflow:FCMConnection" xmi:id="FCMConnection_1" targetNode="FCMComposite_1_2" sourceNode="FCMComposite_1_1" sourceTerminalName="OutTerminal.out" targetTerminalName="InTerminal.in"/>
<connections xmi:type="eflow:FCMConnection" xmi:id="FCMConnection_7" targetNode="FCMComposite_1_7" sourceNode="FCMComposite_1_1" sourceTerminalName="OutTerminal.failure" targetTerminalName="InTerminal.in"/>
<connections xmi:type="eflow:FCMConnection" xmi:id="FCMConnection_8" targetNode="FCMComposite_1_7" sourceNode="FCMComposite_1_1" sourceTerminalName="OutTerminal.catch" targetTerminalName="InTerminal.in"/>
<connections xmi:type="eflow:FCMConnection" xmi:id="FCMConnection_6" targetNode="FCMComposite_1_5" sourceNode="FCMComposite_1_2" sourceTerminalName="OutTerminal.out" targetTerminalName="InTerminal.in"/>
</composition>
<propertyOrganizer/>
<stickyBoard/>
</eClassifiers>
</ecore:EPackage>
|
--> Now I create a message flow MQINput Node --> Compute Node only
--> Create a Datasource and table for inserting some values input as above file.
--> Table Name : MsgFlow_Events
Column Name Data Type Nullable
EVENTSOURCEDESCRIPTION NVARCHAR2(256) Yes
QUEUENAME NVARCHAR2(256) Yes
EVENTSOURCENAME NVARCHAR2(256) Yes
DATALOCATION NVARCHAR2(256) Yes
Compute Node Code :
| Code: |
DECLARE inRef REFERENCE TO InputRoot.XMLNSC.ecore:EPackage.eClassifiers.composition.nodes;
DECLARE eventSourceDescription CHARACTER inRef.monitorEvents.eventSourceDescription;
DECLARE queueName CHARACTER inRef.queueName;
DECLARE eventSourceName CHARACTER inRef.monitorEvents.eventSourceName;
DECLARE dataLocation CHARACTER inRef.monitorEvents.eventXMLDoc.applicationData.dataLocation;
PASSTHRU('insert into MsgFlow_Events (EVENTSOURCEDESCRIPTION,QUEUENAME,EVENTSOURCENAME,DATALOCATION) values (?,?,?,?)',eventSourceDescription,queueName,eventSourceName,dataLocation);
|
--> Then data will be inserted for first Event in above xml(input) file i.e Failure terminal
Select * from MsgFlow_Events
EVENTSOURCEDESCRIPTION QUEUENAME EVENTSOURCENAME DATALOCATION
Failure terminal QIN QIN.terminal.failure $ExceptionList
Failure terminal QIN QIN.terminal.failure $ExceptionList
--> But I want to insert both Events please give me solution for this ...
_________________
Thanks.... |
|
| Back to top |
|
 |
|
|
|
| |
|
Page 1 of 1 |
|
You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
|
|
|
|
