For a deeper look into our Elektron API, look into:
Overview | Quickstart | Documentation | Downloads | Tutorials | Articles
Hello, We have used your Java based Websocket MarketPrice batch example. It is working fine and we are getting updates continuously without any delay. However if we want to add a delay lets say of 5 seconds, then how can we do it. Now we are constantly receiving updates through websocket.
We need to add the rates in database but not too fast, atleast with delay of 5 seconds. Please assist where to mention the delay for this websocket based example to receive RIC updates in every 5 sec.
If you are using an in house TREP system, you can ask your Market Data team to setup a Conflated service for you which can limit updates to the configured interval period.
Otherwise, you could implement conflation logic at your application level, to limit how often your write to your database i.e. apply any updates to an application level representation for each RIC and then flush the object values to the database every 5 seconds if any values have changed.
What if we sleep the WebSocketAdapter Listener for 5 seconds in onTextMessage callback. We tried it, its working but don't know the impact. Will the latest update messages will be discarded by the Listener thread? We need to update the rates in database so continuous update without breadth is making the system slow. So please let us know if adding sleep in listener is one of the correct way to do it?
Absolutely agree with @Umer Nalla, conflated service would be the most efficient way.
As another option, one can request a snapshot request, every 5 seconds, for example:
{
"ID": 2,
"Key": {
"Name": "MSFT.O"
},
"Streaming": false
}
So, adding streaming=false, will give us the updates with a delay? and where should we specify the delay?
Specifying non streaming request will give you only one image response, which you will have to snap again, every 5 seconds. A better approach is to have the service conflate the streaming updates at source.
What if we sleep the WebSocketAdapter Listener for 5 seconds in onTextMessage callback. We tried it, its working but don't know the impact. Will the latest update messages will be discarded by the Listener thread? We need to update the rates in database so continuous update without breadth is making the system slow. So please let us know if adding sleep in listener is one of the correct way to do it?
And if not the above, as @zoya.farberov suggested doing streaming=false will help.
So it will gives us the delayed rates. Where can we specify the the delay?
suggestred
Sleeping in the callback is not recommended as, it does not slow down the incoming updates, but will queue them in an internal buffer instead. So after 1 minute, your application will be getting data which is 1 minute old, and after a while application might crash, due to memory overrun.
