...
Code Block |
---|
<EagleML xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequestSync" eaglemlType="RunTaskRequest" eaglemlVersion="2.0"> <header> <messageId>ID:EXTRACT</messageId> <sentBy>http://www.client.com</sentBy> <sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_out_extract_service</sendTo> <replyTo>http://www.client.com/Eagle Control Messages</replyTo> </header> <taskIdentifier> <correlationId>MC2_ENTITY_XML_NUG_{GUID}</correlationId> <businessTaskId>YIELDCURVEEXTRACT</businessTaskId> </taskIdentifier> <taskTypeEnum>LOAD</taskTypeEnum> <synchronousExecution>no</synchronousExecution> <taskParameters> <taskParameter> <name>ActionType</name> <value>EXTRACT</value> </taskParameter> <taskParameter> <name>FeedType</name> <value>ENTITYEXTRACT</value> </taskParameter> <taskParameter> <name>maxrows</name> <value>10</value> </taskParameter> <taskParameter> <name>RecordCountPerNugget</name> <value>2</value> </taskParameter> <taskParameter> <name>ExtractDeliveryMethod</name> <dataType>S</dataType> <value>MESSAGE</value> </taskParameter> <taskParameter> <name>ReplyDeliveryMethod</name> <dataType>S</dataType> <value>MESSAGE</value> </taskParameter> <taskParameter> <name>EnableReplyDelivery</name> <dataType>S</dataType> <value>Y</value> </taskParameter> <taskParameter> <name>MessagingExtractDeliveryURI</name> <dataType>S</dataType> <value>kafkamessaging:kafkaExtractProducer</value> </taskParameter> <taskParameter> <name>MessagingReplyDeliveryURI</name> <dataType>S</dataType> <value>kafkamessaging:kafkaReplyProducer</value> </taskParameter> </taskParameters> </EagleML> |
Reply by REST
Code Block | ||
---|---|---|
| ||
<EagleML eaglemlVersion="2-0"
eaglemlType="TaskStatusResponse"
xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd"
xsi:type="TaskStatusResponse"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0">
<header>
<messageId>G4ISE97BYW4FLJE5</messageId>
<inReplyTo>http://www.client.com/Eagle Control Messages</inReplyTo>
<sentBy>http://www.eagleinvsys.com/</sentBy>
<creationTimestamp>2020-06-09T15:08:08-04:00</creationTimestamp>
</header>
<statusItem>
<taskIdentifier>
<correlationId correlationIdScheme="correlationIdScheme">MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13</correlationId>
<businessTaskId businessTaskIdScheme="businessTaskIdScheme">YIELDCURVEEXTRACT</businessTaskId>
</taskIdentifier>
<status>SUCCESS</status>
<severityCode>0</severityCode>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_1_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_2_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_3_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_4_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_5_LAST_2_20200609.xml</extractFilename>
<objectCount>10</objectCount>
<reason>
<reasonTypeEnum>INFO</reasonTypeEnum>
<reasonCode>NuggetCount</reasonCode>
<description>5</description>
</reason>
</statusItem>
</EagleML> |
Results written on disk by mc2kafka consumers (mc2_kafka_messaging_(3)__15:08:08.632.xml - with reply content):
...