-
Issues with our API Connection (Error code 403 / MainThread 9584 / [MainThread 9256 / MainThread 102
Hi Community, since this week we are experiencing issues with our API process/connection. We are using Eikon. During the day we have different processes which are retrieving different data points via API connection. Some retrieval processes don’t return any data (just error messages), others retrieve data but not for all…
-
[EMA/C++] FieldList/UpdateMsg performance with multithreading
Hi We're in the process of developing a C++ application that will utilize RTSDK to send a rather large amounts of messages (200k+) in periodic bursts. We're basing this on Cpp EMA, and we're running multiple threads each with its own InteractiveProvider to spread business logic and encoding load between different CPU…
-
Potential deadlock with OmmConsumer
We are creating an EMA consumer, and then opening item streams (100 items batched in each ReqMsg) with the consumer. We simply stop seeing new messages a few minutes after the consumer is established, without any exceptions or errors. This happens while the loop of opening item streams is ongoing. Debugging shows that…
-
What is the best threading model for 3k symbol subscription + low latency
Hi, We have a single-threaded feed application (same as rmdstestclient) that is currently experiencing huge latency when subscribing to ~3k Shenzhen symbols. We were looking into the possibility that our app is a slow consumer, and that we may need to perform some changes on our end. We believe that the single-threaded…
-
multithreading callback
Hello, everyone, Is it possible that I create one OmmConsumer instance, register some rics for quote and the callback function OnRefreshMsg and OnUpdateMsg will be called by multiple threads ? It seems that currently only one thread is callback, which may suffer performance problem. Thanks
-
Filling EMA messages is not multi-thread-safe.
Hello I have an interactive provider, that uses a dedicated thread per connected consumer to build up EMA messages and send them to the corresponding consumer. Of course I use individual message objects per thread, of type RefreshMsg / UpdateMsg with a FieldList therein. However, if the code that fills the message objects…
-
multiple thread requests?
Can Refinitiv's DataScope Select (DSS) handle multiple thread requests? We are calling DSS web API to retrieve data from web service and want to know if it can handle multiple thread requests. If yes, can you provide us sample codes for developers?
-
When processing UpdateMsg using multiple threads, keep getting exception when opening the message. I
When processing UpdateMsg using multiple threads, keep getting exception when opening the message. Is there way to clone a message for further processing. I believe the UpdateMsg objects keep getting overridden. Exception: 2019-09-09 11:29:29 [pool-1-thread-1] ERROR c.b.e.f.reuters.parser.MessageParser - Error…
-
Multi threading
For multi threading we were looking into example 410. However in this example different users are used to create multiple OmmConsumers. We would prefer a multi-threaded solution that works with only one user. We tried creating multiple consumers using the same login, but that doesn't seem to work with the token refreshing.…
-
Multi threading Python Rest API examples
Hi, Can you share any examples to multi-thread requests to get data from Reuters TRTH in Python?
-
System.BadImageFormatException: Could not load file or assembly 'ThomsonReuters.Desktop.SDK.DataAcce
Hi, I am trying to query live Reuters data in a multi-threaded .NET Console application. My implementation does not use the Dispatcher.Frame but a multi-threaded env where I have one thread which is waiting for the required data to be fetched from Reuters (similar to what DispatcherFrame implementation does). I got the…
-
FieldDictionary thread safety
Hi, My app creates and loads a single data dictionary on startup and has multiple threads using it afterwards for field list decoding. May I know if the read-methods of the data dictionary are thread-safe? In particular, my concern is these methods: FieldDictionary.getFidDef() FieldDictionary.expandedValueFor()…
-
[EMA CPP] Trade Safety of a class that inherits from OmmConsumerClient
Hi, suppose I have a class that inherits from OmmConsumerClient: class Client : public thomsonreuters::ema::access::OmmConsumerClient { public: Client(); ~Client(); void onRefreshMsg(const thomsonreuters::ema::access::RefreshMsg&, msg, const thomsonreuters::ema::access::OmmConsumerEvent& event); void onUpdateMsg(const…
-
DLL with DataAccess SDK C#
Hi there, I am able to run the c# DataApiUsageExampleRealtimeData as a console application all right. Now that I need the Eikon Data API within a DLL.I have referenced the "ThomsonReuters.Desktop.SDK.DataAccess.dll" and the other UDAP dll alright. I cannot get any events to fire for DataReceivedCallbackInit after this code…
-
Thread lock on MessageQueue.dequeue call in rfa.jar
rfa.jar is used in a batch job that snaps the quotes mid-day and saves to db. Time to time, a call to EventSourceImpl.destroy() gets stuck forcing us to kill and restart the batch job. Below is the call stack. Has anyone seen this before? "XXEngine" daemon prio=6 tid=0x0000000034a1d800 nid=0x5bb4 in Object.wait()…
-
RFA.NET - Seperate threads - event dispatching and event processing
Hi, As part of using RFA.Net in order to get market price information, we implemented: QueueDispatcher which runs in the background in thread and do eventQueue.Dispatch(); In the other hand we created EventClient implemented Client interface, and use it in the interest registration (registrations are in stream mode). My…
-
Can multiple encoding threads allocate RsslGetBuffer with the same RsslChannel?
Given an Interactiver Provider with multiple encoding threads, can multiple encoding threads currently use the same RsslChannel in call to RsslGetBuffer()?
-
Multi thread to call API. Error: "Too Many Request"
Hi, I need to employ multi-threading in order to reduce the time taken to call multiple functions. With multiple reference IDs, I used a Parallel.For loop to retrieve profile results in C#. Yet the following error occurs. Even if I set the MaxDegreeOfParallelism to 2. This error occurs sometime. Can someone advice /…
-
event queue and thread affinity
Hi, I am investigating different RFA configuration especially, 'Single and Dual Threaded with Event Queue' client model. Is it possible to pin CPU to thread that process RFA or event queue?
-
OpenDACS API thread-safe?
Can you confirm if Open DACS API is thread-safe? we would like to share DACSAuthorizationAgent on multi-thread, Do we need to add lock mechanism in our application.
-
Correct Settings for RFA 8 app using Horizontal Scaling
We have a newly developed application that been implemented in the "Horizontal Scaling" model described in the Threading section of chapter 17 of the RFA 8 C++ Developers Guide. EG: Separate Event Queues, Separate Sessions, and Separate Connections. The question is twofold: One: In the Threading section of the…
-
Eikon .Net API - Multiple time series subscriptions are causing problems
I am migrating an application to Eikon, and I am getting some serious issues with the time series subscription. This is my first encounter with Eikon and TR in general (although I have experience with other platforms), so I think this might simply be a case of teething issues. What I'm trying to achieve is fairly simple.…
-
How to safely redispatch an RsslMsgEvent to another thread
I'd like to offload the processing of a defaultMsgEventCallback to another thread to distribute the data received from the subscriptions among multiple threads rather than the thread on which rsslReactorDispatch is called to prevent being disconnect for buffer overruns in the Elektron Server In order to due so, I'm…
-
APIdisptatch mode behaviour, VA Reactor thread in EMA API
It is my understanding that when a Consumer is set to operate in APIDispatch mode (which is the default), a new internal thread is created to manage VA reactor and it dispatches messages to the callbacks on registered Consumerclient object. Now I would expect this thread to continue to run and dispatch updates as they are…
-
Channel.write() best practices
I am developing a provider application and from some tests that I have done, it seems that writing to the same channel from multiple threads gives lower throughput than using just only one thread to call Channel.write(). Also, from the upajProvPerf source code, it uses only one thread to write to a channel and even though…
-
UPA High CPU Usage?
Please can you help? I am using the UPA API on ASG and I am finding that the thread handling reading and writing to/from UPA API is having 100% CPU. I have done a g profile analysis and the results are attached. They show that some functions have a lot of the CPU time: ripc10IntFlushSess – has 28% of CPU cycles writev –…