I'm calling OmmConsumer.registerClient on 2000 symbols in a fairly tight loop and finding that it just hangs somewhere between 500 and 1500 symbols subscribed every time. I call registerClient for nth time, and it just never returns.
Any suggestions on how to address this? The actual subscription line is below. It works fine for a smaller number of registrations.
consumer.registerClient(reqMsg.clear().serviceName("ELEKTRON_DD").name(ticker),this)
Thanks,
Shawn
Hi @shawn11,
Attached, please find a helper example that reads a list of RICs from a file and requests them as a batch. It's a variation on MarketPrice Batch example 370 within SDK.
You will need to increase the guaranteed output buffers on your channel, I just tested with:
<GuaranteedOutputBuffersvalue="5000"/>
Let us know how this works for you,
-Zoya
Please verify that:
Hi @shawn11
I have a simple EMA Java test app that reads the RICs from a file and calls registerClient for them in a tight loop and have used this for certainly more than 2000 RICs without problems - just tried with over 4000 RICs and its receiving updates fine. This loop is executed on the main application thread.
One thing I did note is that it appears that you are calling registerClient from within the callback client class. Is this loop invoked directly or indirectly from one of the callback event handlers such as onRefreshMsg, onUpdateMsg etc? I ask because these callback handlers are executed on an API thread - and you should keep any application level processing to a minimum on this thread - otherwise you impact the ability of the API thread to process any incoming events / messages from the server and could result in the connection being dropped.
Hi @Umer Nalla
What service are you using? I was able to do it with no hangs against DIRECT_FEED, but my account manager recommends we use ELEKTRON_DD, and while I was able to complete the subscriptions against DIRECT_FEED, I didn't get any callbacks.
I'm calling registerClient on the main application thread, not from within one of the OmmConsumerClient callbacks. My callbacks just take the update and store the update to redis.
Hi @shawn11
Sorry but I have been on leave.
DIRECT_FEED is just a placeholder servicename (it is also used as the default servicename by some of our Provider examples - which would allow you to connect your consumer to a dummy provider for testing).
ELEKTRON_DD would be the real service that has been configured for you to use by your TREP team or your TR account manager.
Did you get anywhere with the Batch example and guidance provided by Zoya?
Hi @zoya.farberov, @Umer Nalla,
The example was helpful. Between that and setting GuaranteedOutputBuffers, it appears to be working now.
Thanks,
Shawn
