Hi,
I have this code.
private void ReceiveMessage()
{
var readBuffer = new ArraySegment<byte>(new byte[BUFFER_SIZE]);
MemoryStream memoryStream = null;
byte[] dataBuffer = null;
while (true)
{
var result = WebSocket.ReceiveAsync(readBuffer, Cts.Token);
if (result.IsFaulted)
{
Disconnect();
}
else
{
if (!result.Result.EndOfMessage)
{
if (memoryStream == null)
memoryStream = new MemoryStream(BUFFER_SIZE * 5);
memoryStream.Write(readBuffer.Array, readBuffer.Offset, readBuffer.Count);
readBuffer = new ArraySegment<byte>(new byte[BUFFER_SIZE]);
}
else
{
if (memoryStream != null)
{
memoryStream.Write(readBuffer.Array, readBuffer.Offset, readBuffer.Count);
dataBuffer = memoryStream.GetBuffer();
memoryStream.Dispose();
}
else
{
dataBuffer = readBuffer.Array;
}
break;
}
}
}
/* Received message(s). */
try
{
JArray messages = JArray.Parse(Encoding.ASCII.GetString(dataBuffer));
/* Print the message (format the object string for easier reading). */
Print("RECEIVED on {0}:\n{1}\n", Name, JsonConvert.SerializeObject(messages, Formatting.Indented));
for (int index = 0; index < messages.Count; ++index)
ProcessJsonMsg(messages[index]);
}
catch (Exception ex)
{
Print("Parsing message got error {0}", ex.Message);
Print(" \t error content = {0} ", Encoding.ASCII.GetString(dataBuffer));
}
}
But I still have incomplete message from RPD. Here is the error.
10/08/2021 22:15:18.654 | Parsing message got error After parsing a value an unexpected character was encountered: 9. Path '[0].Fields.WEEK_LOW', line 1, position 8192.
10/08/2021 22:15:18.654 | error content = [{"ID":13,"Type":"Refresh",
"Key":{"Service":"ELEKTRON_DD","Name":"AUDCAD="},"State":{"Stream":"Open","Data":"Ok"},
"Qos":{"Timeliness":"Realtime","Rate":"JitConflated"},"PermData":"AwEBUmw=",
"SeqNumber":26014,"Fields":{"PROD_PERM":526,"RDNDISPLAY":153,"DSPLY_NAME":"ALFA-BANK MOW",
"TIMACT":"05:15:00","NETCHNG_1":-0.0001,"HIGH_1":0.9202,"LOW_1":0.9190,"CURRENCY":"CAD",
"ACTIV_DATE":"2021-08-11","OPEN_PRC":0.9194,"HST_CLOSE":0.9198,"BID":0.9197,"BID_1":0.9197,
"BID_2":0.9197,"ASK":0.9199,"ASK_1":0.9198,"ASK_2":0.9198,"ACVOL_1":3717,"TRD_UNITS":"4DP ",
"PCTCHNG":-0.01,"OPEN_BID":0.9194,"OPEN_ASK":0.9201,"CLOSE_BID":0.9198,"CLOSE_ASK":0.9203,
"NUM_MOVES":9630,"OFFCL_CODE":"ALFN ","HSTCLSDATE":"2021-08-10","YRHIGH":0.9993,"YRLOW":0.9147,
"BCKGRNDPAG":"ALFH","BID_NET_CH":-0.0001,"BID_TICK_1":"???","MID_PRICE":0.9198,"MID_NET_CH":-0.0003,
"MID_CLOSE":0.9201,"HIGHTP_1":"B","LOWTP_1":"A","BID_HIGH_1":0.9202,"BID_LOW_1":0.9183,
"YRBIDHIGH":0.9993,"YRBIDLOW":0.9146,"HST_CLSBID":0.9198,"HSTCLBDDAT":"2021-08-10",
"NUM_BIDS":3717,"RECORDTYPE":209,"ACT_TP_1":"B???","ACT_TP_2":"B???","ACT_TP_3":"B???",
"SEC_ACT_1":0.9199,"SEC_ACT_2":0.9198,"SEC_ACT_3":0.9198,"SC_ACT_TP1":" A","SC_ACT_TP2":" A",
"SC_ACT_TP3":" A","OPEN_TIME":"21:13:00","HIGH_TIME":"21:17:00","LOW_TIME":"01:15:00",
"YRHIGHDAT":"2021-02-25","YRLOWDAT":"2021-07-30","IRGPRC":-0.01,"TIMCOR":"01:15:03",
"PRIMACT_1":0.9197,"PRIMACT_2":0.9197,"PRIMACT_3":0.9197,"BASE_CCY":"AUD","BCAST_REF":" ",
"CROSS_SC":"1E+00","DLG_CODE1":"ALFN ","DLG_CODE2":"ALFN ","DLG_CODE3":"ALFN ",
"CTBTR_1":"ALFA-BANK ","CTBTR_2":"ALFA-BANK ","CTBTR_3":"ALFA-BANK ","CTB_LOC1":"MOW",
"CTB_LOC2":"MOW","CTB_LOC3":"MOW","CTB_PAGE1":"ALFH","CTB_PAGE2":"ALFH","CTB_PAGE3":"ALFH",
"VALUE_DT1":"2021-08-11","VALUE_DT2":"2021-08-11","VALUE_DT3":"2021-08-11","SEC_HIGH":0.9211,
"SEC_HI_TP":"A","SEC_LOW":0.9190,"SEC_LO_TP":"B","OPEN_TYPE":"B ","CLOSE_TYPE":"B ",
"BKGD_REF":"Aus$/Can$","GEN_TEXT16":" ","GEN_VAL3":0.9201,"GEN_VAL4":null,"GV1_TEXT":"CROSS ",
"GV2_TEXT":"AUDCAD","GV4_TEXT":"SPOT","VALUE_TS1":"05:15:17","VALUE_TS2":"05:15:06","VALUE_TS3":"05:14:56",
"QUOTIM":"05:15:17","GEN_VAL5":0.9217,"GEN_VAL6":0.9237,"GEN_VAL7":0.9196,"GEN_VAL8":0.9238,"GEN_VAL9":0.9197,
"GEN_VAL10":0.9226,"GV5_TEXT":"OP_BID","GV6_TEXT":"BID_HI","GV7_TEXT":"BID_LO","GV8_TEXT":"ASK_HI","GV9_TEXT":
"ASK_LO","GV10_TEXT":"OP_ASK","GN_TXT16_2":" ","GV1_TIME":null,"PREF_DISP":6206,"GN_TXT24_1":" ",
"DSO_ID":16416,"RDN_EXCHD2":"NY$","PREV_DISP":60,"ASIA_CL_DT":"2021-08-10","ASIA_CLOSE":0.9212,"ASIA_HI_TM":"21:17:00","ASIA_HIGH":0.9202,
"ASIA_LOW":0.9190,"ASIA_LW_TM":"01:15:00","ASIA_NETCH":-0.0015,"ASIA_OP_TM":"21:13:00","ASIA_OPEN":0.9194,"EURO_CL_DT":"2021-08-10",
"EURO_CLOSE":0.9204,"EURO_HI_TM":"05:14:00","EURO_HIGH":0.9198,"EURO_LOW":0.9196,"EURO_LW_TM":"05:00:00","EURO_NETCH":-0.0007,
"EURO_OP_TM":"05:00:00","EURO_OPEN":0.9188,"US_CL_DT":"2021-08-10","US_CLOSE":0.9198,"US_HI_TM":"12:24:00","US_HIGH":0.9237,
"US_LOW":0.9197,"US_LW_TM":"14:58:00","US_NETCH":-0.0020,"US_OP_TM":"11:00:00","US_OPEN":0.9227,"ASK_SPREAD":0.9183,"BID_SPREAD":0.9188,
"MID_SPREAD":0.9196,"MONTH_HIGH":0.9311,"MONTH_LOW":0.9153,"PCTCHG_3M":-3.05,"PCTCHG_6M":-6.62,"PCTCHG_MTD":0.44,"PCTCHG_YTD":-6.11,
"QUOTE_DATE":"2021-08-11","WEEK_HIGH":0.9244,"WEEK_LOW":0.
I had never received this error until 2 - 3 weeks ago when Refinitiv had tried to add more services. Do you have any clue to solve this problem?
Regards,
