How to get Webscoket MarketPrice updates based on delay(5 sec for example) and not constant updates.

amar.a.panigrahi

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.

umer.nalla

Hi @amar.a.panigrahi

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.

zoya faberov

Hi @amar.a.panigrahi,

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
}

amar.a.panigrahi

https://community.developers.refinitiv.com/discussion/comment/30678#Comment_30678

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?

amar.a.panigrahi

https://community.developers.refinitiv.com/discussion/comment/30684#Comment_30684

So, adding streaming=false, will give us the updates with a delay? and where should we specify the delay?

amar.a.panigrahi

@umer.nalla @zoya faberov

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 faberov suggested doing streaming=false will help.

So it will gives us the delayed rates. Where can we specify the the delay?
suggestred

Gurpreet

https://community.developers.refinitiv.com/discussion/comment/30925#Comment_30925

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.

Gurpreet

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.