Failed subscription causes resubscription
Alex.Reynolds
Newcomer
in RFA
Hello, if we subscribe to an invalid ric (which occasionally occurs), the RFA api appears to continue to attempt to resubscribe and fail, giving us closed stream over and over.
We are using registerClient and reissueClient as necessary.
We are using: rfa8.0.0.L1.linux.rrg.
Is there a way to change the QoS to stop this from happening?
Thanks,
-Alex
The resubmission happens ~every minute. Here I subscribe with a fake RIC: IBMdsfdsfd
stream_state=4 data_state=2 status_code=1 status_text=The record could not be found
stream_state=4 data_state=2 status_code=1 status_text=The record could not be found
Your website doesn't allow me to update the log as a file, so I'm including the full body here (sorry).
<!-- Attempt to Connect to 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:15:630 -->
<!-- Connected to 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:15:632 -->
<!-- Outgoing Message to 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:15:632 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<requestMsg domainType="RSSL_DMT_LOGIN" streamId="1" containerType="RSSL_DT_NO_DATA" flags="0x4 (RSSL_RQMF_STREAMING)" dataSize="0">
<key flags="0x26 (RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE|RSSL_MKF_HAS_ATTRIB)" name="svcWangEngQA" nameType="1" attribContainerType="RSSL_DT_ELEMENT_LIST">
<attrib>
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="ApplicationId" dataType="RSSL_DT_ASCII_STRING" data="256"/>
<elementEntry name="SingleOpen" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="InstanceId" dataType="RSSL_DT_ASCII_STRING" data="
<Instance Id>"/>
<elementEntry name="DownloadConnectionConfig" dataType="RSSL_DT_UINT" data="1"/>
</elementList>
</attrib>
</key>
<dataBody></dataBody>
</requestMsg>
<!-- Incoming Message from 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:15:636 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<refreshMsg domainType="RSSL_DMT_LOGIN" streamId="1" containerType="RSSL_DT_NO_DATA" flags="0x168 (RSSL_RFMF_HAS_MSG_KEY|RSSL_RFMF_SOLICITED|RSSL_RFMF_REFRESH_COMPLETE|RSSL_RFMF_CLEAR_CACHE)" groupId="0" dataState="RSSL_DATA_OK" streamState="RSSL_STREAM_OPEN" code="RSSL_SC_NONE" text="Login accepted by host PRDMDS22WHSSADS01." dataSize="0">
<key flags="0x26 (RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE|RSSL_MKF_HAS_ATTRIB)" name="svcWangEngQA" nameType="1" attribContainerType="RSSL_DT_ELEMENT_LIST">
<attrib>
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="AllowSuspectData" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="ApplicationId" dataType="RSSL_DT_ASCII_STRING" data="256"/>
<elementEntry name="ApplicationName" dataType="RSSL_DT_ASCII_STRING" data="ADS"/>
<elementEntry name="Position" dataType="RSSL_DT_ASCII_STRING" data="172.16.54.110"/>
<elementEntry name="ProvidePermissionExpressions" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="ProvidePermissionProfile" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="SingleOpen" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="SupportEnhancedSymbolList" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="SupportOMMPost" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="SupportPauseResume" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="SupportStandby" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="SupportBatchRequests" dataType="RSSL_DT_UINT" data="7"/>
<elementEntry name="SupportViewRequests" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="SupportOptimizedPauseResume" dataType="RSSL_DT_UINT" data="0"/>
</elementList>
</attrib>
</key>
<dataBody></dataBody>
</refreshMsg>
<!-- Outgoing Message to 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:15:637 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<requestMsg domainType="RSSL_DMT_SOURCE" streamId="2" containerType="RSSL_DT_NO_DATA" flags="0x4 (RSSL_RQMF_STREAMING)" dataSize="0">
<key flags="0x8 (RSSL_MKF_HAS_FILTER)" filter="63"/>
<dataBody></dataBody>
</requestMsg>
<!-- Incoming Message from 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:15:639 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<refreshMsg domainType="RSSL_DMT_SOURCE" streamId="2" containerType="RSSL_DT_MAP" flags="0x168 (RSSL_RFMF_HAS_MSG_KEY|RSSL_RFMF_SOLICITED|RSSL_RFMF_REFRESH_COMPLETE|RSSL_RFMF_CLEAR_CACHE)" groupId="0" dataState="RSSL_DATA_OK" streamState="RSSL_STREAM_OPEN" code="RSSL_SC_NONE" text="" dataSize="1102">
<key flags="0x8 (RSSL_MKF_HAS_FILTER)" filter="63"/>
<dataBody>
<map flags="0x0" countHint="0" keyPrimitiveType="RSSL_DT_UINT" containerType="RSSL_DT_FILTER_LIST">
<mapEntry flags="0x0" action="RSSL_MPEA_ADD_ENTRY" key="465">
<filterList containerType="RSSL_DT_ELEMENT_LIST" countHint="0" flags="0x0">
<filterEntry id="1" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="Name" dataType="RSSL_DT_ASCII_STRING" data="MRN"/>
<elementEntry name="SupportsQoSRange" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="QoS" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_QOS">
<arrayEntry qosDynamic="0" qosRate="1" qosTimeliness="1"/>
</array>
</elementEntry>
<elementEntry name="Capabilities" dataType="RSSL_DT_ARRAY">
<array itemLength="1" primitiveType="RSSL_DT_UINT">
<arrayEntry data="5"/>
<arrayEntry data="6"/>
<arrayEntry data="7"/>
<arrayEntry data="8"/>
<arrayEntry data="9"/>
<arrayEntry data="10"/>
<arrayEntry data="11"/>
<arrayEntry data="13"/>
<arrayEntry data="18"/>
<arrayEntry data="19"/>
<arrayEntry data="20"/>
<arrayEntry data="21"/>
<arrayEntry data="23"/>
<arrayEntry data="24"/>
<arrayEntry data="25"/>
<arrayEntry data="26"/>
<arrayEntry data="28"/>
<arrayEntry data="33"/>
<arrayEntry data="126"/>
</array>
</elementEntry>
<elementEntry name="DictionariesProvided" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="DictionariesUsed" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="Vendor" dataType="RSSL_DT_ASCII_STRING" data="Thomson Reuters"/>
</elementList>
</filterEntry>
<filterEntry id="2" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="ServiceState" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="AcceptingRequests" dataType="RSSL_DT_UINT" data="1"/>
</elementList>
</filterEntry>
<filterEntry id="4" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="OpenLimit" dataType="RSSL_DT_UINT" data="160000"/>
</elementList>
</filterEntry>
</filterList>
</mapEntry>
<mapEntry flags="0x0" action="RSSL_MPEA_ADD_ENTRY" key="3023">
<filterList containerType="RSSL_DT_ELEMENT_LIST" countHint="0" flags="0x0">
<filterEntry id="1" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="Name" dataType="RSSL_DT_ASCII_STRING" data="EED_CONF"/>
<elementEntry name="SupportsQoSRange" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="QoS" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_QOS">
<arrayEntry qosDynamic="0" qosRate="3" qosTimeliness="1" qosRateInfo="500"/>
</array>
</elementEntry>
<elementEntry name="Capabilities" dataType="RSSL_DT_ARRAY">
<array itemLength="1" primitiveType="RSSL_DT_UINT">
<arrayEntry data="5"/>
<arrayEntry data="6"/>
<arrayEntry data="7"/>
<arrayEntry data="8"/>
<arrayEntry data="9"/>
<arrayEntry data="10"/>
<arrayEntry data="11"/>
<arrayEntry data="13"/>
<arrayEntry data="18"/>
<arrayEntry data="19"/>
<arrayEntry data="20"/>
<arrayEntry data="21"/>
<arrayEntry data="23"/>
<arrayEntry data="24"/>
<arrayEntry data="25"/>
<arrayEntry data="26"/>
<arrayEntry data="28"/>
<arrayEntry data="33"/>
<arrayEntry data="126"/>
</array>
</elementEntry>
<elementEntry name="DictionariesProvided" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="DictionariesUsed" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="Vendor" dataType="RSSL_DT_ASCII_STRING" data="Thomson Reuters"/>
</elementList>
</filterEntry>
<filterEntry id="2" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="ServiceState" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="AcceptingRequests" dataType="RSSL_DT_UINT" data="1"/>
</elementList>
</filterEntry>
<filterEntry id="4" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="OpenLimit" dataType="RSSL_DT_UINT" data="160000"/>
</elementList>
</filterEntry>
</filterList>
</mapEntry>
<mapEntry flags="0x0" action="RSSL_MPEA_ADD_ENTRY" key="2023">
<filterList containerType="RSSL_DT_ELEMENT_LIST" countHint="0" flags="0x0">
<filterEntry id="1" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="Name" dataType="RSSL_DT_ASCII_STRING" data="EED_DELAYED"/>
<elementEntry name="SupportsQoSRange" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="QoS" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_QOS">
<arrayEntry qosDynamic="0" qosRate="3" qosTimeliness="2" qosRateInfo="500"/>
</array>
</elementEntry>
<elementEntry name="Capabilities" dataType="RSSL_DT_ARRAY">
<array itemLength="1" primitiveType="RSSL_DT_UINT">
<arrayEntry data="5"/>
<arrayEntry data="6"/>
<arrayEntry data="7"/>
<arrayEntry data="8"/>
<arrayEntry data="9"/>
<arrayEntry data="10"/>
<arrayEntry data="11"/>
<arrayEntry data="13"/>
<arrayEntry data="18"/>
<arrayEntry data="19"/>
<arrayEntry data="20"/>
<arrayEntry data="21"/>
<arrayEntry data="23"/>
<arrayEntry data="24"/>
<arrayEntry data="25"/>
<arrayEntry data="26"/>
<arrayEntry data="28"/>
<arrayEntry data="33"/>
<arrayEntry data="126"/>
</array>
</elementEntry>
<elementEntry name="DictionariesProvided" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="DictionariesUsed" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="Vendor" dataType="RSSL_DT_ASCII_STRING" data="Thomson Reuters"/>
</elementList>
</filterEntry>
<filterEntry id="2" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="ServiceState" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="AcceptingRequests" dataType="RSSL_DT_UINT" data="1"/>
</elementList>
</filterEntry>
<filterEntry id="4" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="OpenLimit" dataType="RSSL_DT_UINT" data="160000"/>
</elementList>
</filterEntry>
</filterList>
</mapEntry>
<mapEntry flags="0x0" action="RSSL_MPEA_ADD_ENTRY" key="258">
<filterList containerType="RSSL_DT_ELEMENT_LIST" countHint="0" flags="0x0">
<filterEntry id="1" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="Name" dataType="RSSL_DT_ASCII_STRING" data="EED"/>
<elementEntry name="SupportsQoSRange" dataType="RSSL_DT_UINT" data="0"/>
<elementEntry name="QoS" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_QOS">
<arrayEntry qosDynamic="0" qosRate="1" qosTimeliness="1"/>
</array>
</elementEntry>
<elementEntry name="Capabilities" dataType="RSSL_DT_ARRAY">
<array itemLength="1" primitiveType="RSSL_DT_UINT">
<arrayEntry data="5"/>
<arrayEntry data="6"/>
<arrayEntry data="7"/>
<arrayEntry data="8"/>
<arrayEntry data="9"/>
<arrayEntry data="10"/>
<arrayEntry data="11"/>
<arrayEntry data="13"/>
<arrayEntry data="18"/>
<arrayEntry data="19"/>
<arrayEntry data="20"/>
<arrayEntry data="21"/>
<arrayEntry data="23"/>
<arrayEntry data="24"/>
<arrayEntry data="25"/>
<arrayEntry data="26"/>
<arrayEntry data="28"/>
<arrayEntry data="33"/>
<arrayEntry data="126"/>
</array>
</elementEntry>
<elementEntry name="DictionariesProvided" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="DictionariesUsed" dataType="RSSL_DT_ARRAY">
<array itemLength="0" primitiveType="RSSL_DT_ASCII_STRING">
<arrayEntry data="RWFFld"/>
<arrayEntry data="RWFEnum"/>
</array>
</elementEntry>
<elementEntry name="Vendor" dataType="RSSL_DT_ASCII_STRING" data="Thomson Reuters"/>
</elementList>
</filterEntry>
<filterEntry id="2" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="ServiceState" dataType="RSSL_DT_UINT" data="1"/>
<elementEntry name="AcceptingRequests" dataType="RSSL_DT_UINT" data="1"/>
</elementList>
</filterEntry>
<filterEntry id="4" action="RSSL_FTEA_SET_ENTRY" flags="0x0" containerType="RSSL_DT_ELEMENT_LIST">
<elementList flags="0x8 (RSSL_ELF_HAS_STANDARD_DATA)">
<elementEntry name="OpenLimit" dataType="RSSL_DT_UINT" data="160000"/>
</elementList>
</filterEntry>
</filterList>
</mapEntry>
</map>
</dataBody>
</refreshMsg>
<!-- Outgoing Message to 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:27:208 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<requestMsg domainType="RSSL_DMT_MARKET_PRICE" streamId="3" containerType="RSSL_DT_NO_DATA" flags="0x46 (RSSL_RQMF_HAS_PRIORITY|RSSL_RQMF_STREAMING|RSSL_RQMF_HAS_QOS)" qosDynamic="0" qosRate="1" qosTimeliness="1" priorityClass="1" priorityCount="1" dataSize="0">
<key flags="0x7 (RSSL_MKF_HAS_SERVICE_ID|RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE)" serviceId="258" name="IBMdsfdsfd" nameType="1"/>
<dataBody></dataBody>
</requestMsg>
<!-- Incoming Message from 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:06:27:256 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<statusMsg domainType="RSSL_DMT_MARKET_PRICE" streamId="3" containerType="RSSL_DT_NO_DATA" flags="0x28 (RSSL_STMF_HAS_MSG_KEY|RSSL_STMF_HAS_STATE)" dataState="RSSL_DATA_SUSPECT" streamState="RSSL_STREAM_CLOSED" code="RSSL_SC_NOT_FOUND" text="The record could not be found" dataSize="0">
<key flags="0x7 (RSSL_MKF_HAS_SERVICE_ID|RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE)" serviceId="258" name="IBMdsfdsfd" nameType="1"/>
<dataBody></dataBody>
</statusMsg>
<!-- Outgoing Message to 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:07:12:209 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<requestMsg domainType="RSSL_DMT_MARKET_PRICE" streamId="4" containerType="RSSL_DT_NO_DATA" flags="0x46 (RSSL_RQMF_HAS_PRIORITY|RSSL_RQMF_STREAMING|RSSL_RQMF_HAS_QOS)" qosDynamic="0" qosRate="1" qosTimeliness="1" priorityClass="1" priorityCount="1" dataSize="0">
<key flags="0x7 (RSSL_MKF_HAS_SERVICE_ID|RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE)" serviceId="258" name="IBMdsfdsfd" nameType="1"/>
<dataBody></dataBody>
</requestMsg>
<!-- Incoming Message from 'PRDMDS22WHSSADS01:14002' on 'localhost' interface -->
<!-- Time: 17:07:12:237 -->
<!-- rwfMajorVer="14" rwfMinorVer="1" -->
<statusMsg domainType="RSSL_DMT_MARKET_PRICE" streamId="4" containerType="RSSL_DT_NO_DATA" flags="0x28 (RSSL_STMF_HAS_MSG_KEY|RSSL_STMF_HAS_STATE)" dataState="RSSL_DATA_SUSPECT" streamState="RSSL_STREAM_CLOSED" code="RSSL_SC_NOT_FOUND" text="The record could not be found" dataSize="0">
<key flags="0x7 (RSSL_MKF_HAS_SERVICE_ID|RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE)" serviceId="258" name="IBMdsfdsfd" nameType="1"/>
<dataBody></dataBody>
</statusMsg>
0
Best Answer
-
I figured it out. On StreamClosed Response I failed to disseminate the message to the connected clients. This appears to causes the client's RFA connection to re-request every minute (I do not have logic to do so myself). Publishing the StreamClosed event to all relevant clients fixed the issue.
0
Answers
-
Behaviour you mentioned below is not correct.
"the RFA api appears to continue to attempt to resubscribe and fail, giving us closed stream over and over."
Normally in case of invalid RIC or Record could not be found , application will receive Response Status Message with stream state is Closed. And RFA will not attemp to resubscribe the item on behalif of application. Below is sample response message from StarterConsumer in case of using invalid RIC. You can try the example with invalid RIC and compare the result with your application.
2018 Apr 11 08:07:48.655 ST GMT+07:00 C9C 1118 603 TRACE <- Received MMT_MARKE
T_PRICE Status INVALIDRIC
serviceName : API_ELEKTRON_EDGE_TOKYO
symbolName : INVALIDRIC
********************Status**********************
streamState : Closed
dataState : Suspect
statusCode : NotFound
statusText : The record could not be found.-Do you have sample response message you received when subscribe invalid RIC?
-Can you turn on RSSL tracing log to see incomming and outgoing messages between RFA and Server?
0 -
@moragodkrit.chumsri_1 Updated with the xml log. Sorry for the bad format, but the website won't let me upload it as a seperate file (invalid file type).
0 -
@Alex.Reynolds
I have reviewed the RSSL tracing log and found that both item request message is just simple streaming request but the time between the first and second request message is around 45 sec (17:06:27:208 -->17:07:12:209). Application immediately received the response message after it send the item request. It seems to be the case that application re-send the request message after item stream is closed.- Have you set any special flag in the request message or having any additional application logic to send item request again after item stream is closed?
- Have you logged the handle returned by event.getHandle()? Is this the same one?
- Can you please try the same item with StarterConsumer?
- And can you please verify what are differences between the codes in you application and the codes from StarterConsumer example?
Testing the same scenario with StarterConsumer example and not found the issue with the RFA version 8.0.0 you mentioned.
I received only one close message as below tracing log<!-- Outgoing Message to '192.168.27.46:14002' on 'localhost' interface -->
<!-- Time: 10:30:00:836 -->
<!-- rwfMajorVer="14" rwfMinorVer="0" -->
<requestMsg domainType="RSSL_DMT_MARKET_PRICE" streamId="3" containerType="RSSL_DT_NO_DATA" flags="0x66 (RSSL_RQMF_HAS_PRIORITY|RSSL_RQMF_STREAMING|RSSL_RQMF_NO_REFRESH|RSSL_RQMF_HAS_QOS)" qosDynamic="0" qosRate="1" qosTimeliness="1" priorityClass="1" priorityCount="2" dataSize="0">
<key flags="0x7 (RSSL_MKF_HAS_SERVICE_ID|RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE)" serviceId="2115" name="TEST.BK" nameType="1"/>
<dataBody>
</dataBody>
</requestMsg>
<!-- Incoming Message from '192.168.27.46:14002' on 'localhost' interface -->
<!-- Time: 10:30:01:696 -->
<!-- rwfMajorVer="14" rwfMinorVer="0" -->
<statusMsg domainType="RSSL_DMT_MARKET_PRICE" streamId="3" containerType="RSSL_DT_NO_DATA" flags="0x28 (RSSL_STMF_HAS_MSG_KEY|RSSL_STMF_HAS_STATE)" dataState="RSSL_DATA_SUSPECT" streamState="RSSL_STREAM_CLOSED" code="RSSL_SC_NOT_FOUND" text="The record could not be found" dataSize="0">
<key flags="0x7 (RSSL_MKF_HAS_SERVICE_ID|RSSL_MKF_HAS_NAME|RSSL_MKF_HAS_NAME_TYPE)" serviceId="2115" name="TEST.BK" nameType="1"/>
<dataBody>
</dataBody>
</statusMsg>0
Categories
- All Categories
- 3 Polls
- 6 AHS
- 36 Alpha
- 166 App Studio
- 6 Block Chain
- 4 Bot Platform
- 18 Connected Risk APIs
- 47 Data Fusion
- 34 Data Model Discovery
- 690 Datastream
- 1.4K DSS
- 629 Eikon COM
- 5.2K Eikon Data APIs
- 11 Electronic Trading
- 1 Generic FIX
- 7 Local Bank Node API
- 3 Trading API
- 2.9K Elektron
- 1.4K EMA
- 255 ETA
- 559 WebSocket API
- 39 FX Venues
- 15 FX Market Data
- 1 FX Post Trade
- 1 FX Trading - Matching
- 12 FX Trading – RFQ Maker
- 5 Intelligent Tagging
- 2 Legal One
- 25 Messenger Bot
- 3 Messenger Side by Side
- 9 ONESOURCE
- 7 Indirect Tax
- 60 Open Calais
- 279 Open PermID
- 45 Entity Search
- 2 Org ID
- 1 PAM
- PAM - Logging
- 6 Product Insight
- Project Tracking
- ProView
- ProView Internal
- 23 RDMS
- 2K Refinitiv Data Platform
- 716 Refinitiv Data Platform Libraries
- 4 LSEG Due Diligence
- LSEG Due Diligence Portal API
- 4 Refinitiv Due Dilligence Centre
- Rose's Space
- 1.2K Screening
- 18 Qual-ID API
- 13 Screening Deployed
- 23 Screening Online
- 12 World-Check Customer Risk Screener
- 1K World-Check One
- 46 World-Check One Zero Footprint
- 45 Side by Side Integration API
- 2 Test Space
- 3 Thomson One Smart
- 10 TR Knowledge Graph
- 151 Transactions
- 143 REDI API
- 1.8K TREP APIs
- 4 CAT
- 27 DACS Station
- 121 Open DACS
- 1.1K RFA
- 106 UPA
- 194 TREP Infrastructure
- 229 TRKD
- 918 TRTH
- 5 Velocity Analytics
- 9 Wealth Management Web Services
- 95 Workspace SDK
- 11 Element Framework
- 5 Grid
- 19 World-Check Data File
- 1 Yield Book Analytics
- 48 中文论坛
