I am trying to use the websocket example t mrn_console_app.py python script to subscribe to MRN_STORY from our internal TREP infrastructure. I am able to subscribe to a websocket enabled ads using the following rmdstestclient command:
rmdstestclient -h ncmdplm13202-364.dc.gs.com -S IDN_RDF -u BGS -md 33 -itemList MRN_STORY -d 3 -X -dfile $SC/RDMFieldDictionary.GS -l stdout
PROD_PERM : UINT 2 : [10001]
ACTIV_DATE : DATE 4 : [14 MAY 2022]
RECORDTYPE : UINT 1 : [30]
RDN_EXCHD2 : ENUM 2 : [1370]
TIMACT_MS : UINT 4 : [59114397]
GUID : STRING 0 : []
CONTEXT_ID : REAL 3 : [3752]
DDS_DSO_ID : UINT 2 : [8328]
SPS_SP_RIC : STRING 10 : [.[SPSML0L1]
MRN_V_MAJ : STRING 1 : [2]
MRN_TYPE : STRING 5 : [STORY]
MDU_V_MIN : UINT 0 : []
MDU_DATE : DATE 0 : []
MRN_V_MIN : STRING 2 : [10]
MRN_SRC : STRING 9 : [HDC_PRD_A]
MDUTM_NS : TIME 0 : []
FRAG_NUM : UINT 1 : [1]
TOT_SIZE : UINT 1 : [0]
FRAGMENT : STRING 0 : []
When I try to do it with the webscoket example I see that I am setting the service correctly from the initial output:
SENT:
{
"Domain":"Login",
"ID":1,
"Key":{
"Elements":{
"ApplicationId":"256",
"Position":"10.50.92.16"
},
"Name":"XXX",
"Service":"IDN_RDF"
}
}
RECEIVED:
[
. . .
"State":{
"Data":"Ok",
"Stream":"Open",
"Text":"Login accepted by host ncmdplm13202-364.dc.gs.com."
},
"Type":"Refresh"
}
]
but the subscription closes with:
RECEIVED: Status Message
{
"Domain":"NewsTextAnalytics",
"ID":2,
"Key":{
"Name":"MRN_STORY",
"Service":0
},
"State":{
"Code":"SourceUnknown",
"Data":"Suspect",
"Stream":"Closed",
"Text":"A18: Unknown service."
},
"Type":"Status"
}
What am I doing wrong? Note that I am able to succefully subscribe to a MarketByPrice domain instrument (e.g. INTC.O) from this same ads using webscokets
Thanks
