Post / receive Acks on the same channel for ADS websocket in Python

martin.gregory

Hi - I can connected to an ads and off-stream post successfully. Im trying to send a lot of data, so i use a while True loop after receiving the login response to listen to a queue and post.

However this means that the on_message function is never accessed to receive the Acks to the posts.

Do you have any example of how I could achieve this please? (I'm using the Refinitiv examples as a base to connect to the ADS websocket)

Thanks

Martin

Jirapongse

@martin.gregory

Thanks for reaching out to us.

You need to send post messages outside the on_message function.

You can refer to the market_price_posting.py example on GitHub.

The example shows how to send post messages in the main thread outside the on_message function.

I hope that this information is of help.

wasin.w

Hello @martin.gregory

While my colleague already gave you a clear answer, the other WebSocket API Posting resource that might helps you are the following:

• Contributing Data to Refinitiv Real-Time using the Websocket API article

martin.gregory

HI both - thank you very much. I can swap between processing the the incoming Acks and posting but if I'm posting a lot of data this becomes very slow. What I would like to achieve if possible is to concurrently listen for messages coming in whilst continuosuly posting the data that I would like to send to the ads

Thanks

Martin

martin.gregory

Update - I believe I need to somehow run async functions to post and run on_message simultaneously within the websocket connection. Do you have examples to achieve this please?

Thanks

Martin

Jirapongse

@martin.gregory

Currently, all WebSocket API examples are available on GitHub.

martin.gregory

Just an update. I managed to both listen and post concurrently, by starting the posting process in a new separate thread to the login thread, and using queue to pass messages between the 2 threads.

Thanks all for your answers.