streamer keep disconnecting from clinet

saleh.abdallah

Hi , streamer client keep disconnecting from client

client issue

StreamerPricesScript.js?v=29.111:165 Server status Changed to: STALLED

11:51:40.237 StreamerPricesScript.js?v=29.111:165 Server status Changed to: DISCONNECTED:TRYING-RECOVERY

11:51:56.285 mainscript.js?v=29.111:3477 debug GRID_GAINER_SUBSCRIPTION onUnsubscription

11:51:56.285 mainscript.js?v=29.111:3477 debug GRID_ACTIVE_SUBSCRIPTION onUnsubscription

11:51:56.286 mainscript.js?v=29.111:3477 debug GRID_LOSER_SUBSCRIPTION onUnsubscription

11:51:56.286 mainscript.js?v=29.111:3477 debug GRID_GAINER_SUBSCRIPTION onUnsubscription

11:51:56.286 mainscript.js?v=29.111:3477 debug GRID_ACTIVE_SUBSCRIPTION onUnsubscription

11:51:56.287 StreamerPricesScript.js?v=29.111:165 Server status Changed to: DISCONNECTED:WILL-RETRY

11:51:56.290 StreamerPricesScript.js?v=29.111:165 Server status Changed to: CONNECTING

11:51:56.311 StreamerPricesScript.js?v=29.111:165 Server status Changed to: CONNECTED:STREAM-SENSING

11:51:56.320 StreamerPricesScript.js?v=29.111:165

and this is the server log at the same time of the issue i increase the log level to debug .

26-May-24 11:51:30,310|DEBUG|L.pump |PUMP POOLED THREAD 1 |Pumping event in session S32a1467910dfce9dMb3fT4641208^M
U,1023,1,0#0#0#29015.63;1716705360000#28815.82#0.0;1716705540000#28511.55#0.0;1716705960000#28392.9#0.0;1716706020000#27731.35#0.0;1716706080000#26911.74#0.0;1716706200000#26140.91#0.0;1716706320000#26164.02#0.0;1716706440000#27121.77#0.0;1716706500000#26049.5#0.0;1716706560000#26163.86#0.0;1716706620000#28300.02#0.0;1716706680000#26953.77#0.0;1716706740000#29471.26#0.0;1716706800000#30439.58#0.0;1716707040000#30558.22#0.0;1716707100000#31219.78#0.0;1716707400000#32249.42#0.0;1716707460000#32354.43#0.0;1716707520000#31829.35#0.0;1716707640000#31781.21#0.0;1716707700000#33358.79#0.0;1716707760000#32175.8#0.0;1716707880000#28954.56#0.0;1716707940000#29223.81#0.0;1716708000000#26993.09#0.0;1716708060000#26256.83#0.0;1716708120000#22662.07#0.0;1716708180000#23286.04#0.0;1716708900000#23435.9#0.0;1716709320000#24089.1#0.0;1716710760000#23970.46#0.0;1716710820000#22489.29#0.0;1716710940000#21417.02#0.0;1716711000000#20911.72#0.0;1716711060000#22345.57#0.0;1716711120000#24231.05#0.0;1716711180000#26933.32#0.0;1716711240000#29904.11#0.0;1716711360000#30022.76#0.0;1716711480000#31503.92#0.0;1716711600000#32576.2#0.0;1716711660000#32692.98#0.0;1716712260000#32538.57#0.0;1716713460000#30703.83#0.0;1716713520000#29269.98#0.0|^M
26-May-24 11:51:30,310|DEBUG|L.pump |PUMP POOLED THREAD 1 |Pumping event in session S32a1467910dfce9dMb3fT4641208^M
U,1022,1,0#0#0#29015.63;1716705360000#28815.82#0.0;1716705540000#28511.55#0.0;1716705960000#28392.9#0.0;1716706020000#27731.35#0.0;1716706080000#26911.74#0.0;1716706200000#26140.91#0.0;1716706320000#26164.02#0.0;1716706440000#27121.77#0.0;1716706500000#26049.5#0.0;1716706560000#26163.86#0.0;1716706620000#28300.02#0.0;1716706680000#26953.77#0.0;1716706740000#29471.26#0.0;1716706800000#30439.58#0.0;1716707040000#30558.22#0.0;1716707100000#31219.78#0.0;1716707400000#32249.42#0.0;1716707460000#32354.43#0.0;1716707520000#31829.35#0.0;1716707640000#31781.21#0.0;1716707700000#33358.79#0.0;1716707760000#32175.8#0.0;1716707880000#28954.56#0.0;1716707940000#29223.81#0.0;1716708000000#26993.09#0.0;1716708060000#26256.83#0.0;1716708120000#22662.07#0.0;1716708180000#23286.04#0.0;1716708900000#23435.9#0.0;1716709320000#24089.1#0.0;1716710760000#23970.46#0.0;1716710820000#22489.29#0.0;1716710940000#21417.02#0.0;1716711000000#20911.72#0.0;1716711060000#22345.57#0.0;1716711120000#24231.05#0.0;1716711180000#26933.32#0.0;1716711240000#29904.11#0.0;1716711360000#30022.76#0.0;1716711480000#31503.92#0.0;1716711600000#32576.2#0.0;1716711660000#32692.98#0.0;1716712260000#32538.57#0.0;1716713460000#30703.83#0.0;1716713520000#29269.98#0.0|^M
U,1192,1,1000841800581326|||20.0000|10000||-25.926|1716713490000|-||^M
26-May-24 11:51:30,311|ERROR|L.scheduler |PUMP POOLED THREAD 4 |Unexpected error in an internal task
java.lang.ClassCastException: java.lang.String cannot be cast to com.lightstreamer.s.o.xx
at com.lightstreamer.p.po.Q(po.java)
at com.lightstreamer.c.u.b.p(b.java)
at com.lightstreamer.c.u.e.d(e.java)
at com.lightstreamer.c.u.k.d(k.java)
at com.lightstreamer.c.u.b.R(b.java)
at com.lightstreamer.c.u.w.R(w.java)
at com.lightstreamer.c.l.sj.a(sj.java)
at com.lightstreamer.c.l.sj.y(sj.java)
at com.lightstreamer.c.l.sg.b(sg.java)
at com.lightstreamer.c.k.C(k.java)
at com.lightstreamer.c.k.l(k.java)
at com.lightstreamer.c.c.m(c.java)
at com.lightstreamer.s.t5.y(t5.java)
at com.lightstreamer.s.j.q.o(q.java)
at com.lightstreamer.s.j.q.run(q.java)
at com.lightstreamer.s.j.c.run(c.java)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at com.lightstreamer.s.j.k.q.B(q.java)
at com.lightstreamer.s.j.k.x.B(x.java)
at com.lightstreamer.s.j.df.run(df.java)
at com.lightstreamer.s.j.dd.run(dd.java)

the issue appear when the PUMP have that extra "U,1192,1,1000841800581326|||20.0000|10000||-25.926|1716713490000|-||^M" after that casting failed , this is happening on version Lightstreamer-7.4.0

Dario Crivelli

The only possible explanation for the Server exception is that the Data Adapter reused and modified a HashMap already sent through update or smartUpdate, supposedly to issue a subsequent update or smartUpdate.
This is not compliant with the interface contract, which poses this restriction for performance matters.
This assumes that the Data Adapter is a Java in-process one.
Can you check this?

saleh.abdallah

Thank you DarioCrivelli yes that was the issue , the developer who wrote the adapter was updating the HashMap and resend it , i fixed the issue by cloning the map and modify it before sending it back .