Submission via Java EMA suddenly runs slowly
So I submit data via the Java EMA (based on the Contributor.java example code). Everything is fine for a number of days (submitting 295 items that takes 15ms every second), but then suddenly it will start to run very slowly with the same batches taking between 3000ms and 7000ms. Some times this rectifies itself, but a lot of the time it doesn't. There are no error messages or issues reported, just a drastic slowdown.
All this can be sorted out by a simple restart of the code, so what I am wondering is: Is there a way to reset the connection so it starts again programatically?
Best Answer
-
Thanks for reaching out to us.
Something in the application code or API may be wrong.
To investigate this kind of issue, I typically use a Java profiling tool to monitor the Java process.
However, if you are a Refinitiv Developer Connect (RDC) named user, you can submit this issue to the API support team via Contact Premium Support to investigate this issue.
To reset the connection, you can destroy the current OmmConsumer and create a new one.
0
Answers
-
So if I have a method such as the one below, could I call this to reset the OmmConsumer?
public void startTunnelStream() {
if (ommConsumerCreateTime < System.currentTimeMillis() - 60 * 1000) {
isRunning.set(false);
if (tsc != null) {
tsc.close(); // this calls the .clear() on the TunnelStream
tsc = null;
}
// Now load the Refinitiv libraries
final RefinitivConfig login = config.getRefinitivConfig("Primary");
tsc = new TunnelStreamClient(this, login.getUsername(), login.getPassword(), "DDS_TRCE", "");
if (ommConsumer != null) {
log.info("Deleting old OmmConsumer");
ommConsumer.uninitialize();
ommConsumer = null;
}
log.info("Creating OmmConsumer");
ommConsumer = EmaFactory.createOmmConsumer(EmaFactory.createOmmConsumerConfig());
tsc.setOmmConsumer(ommConsumer);
LoginReq loginReq = EmaFactory.Domain.createLoginReq();
long loginHandle = ommConsumer.registerClient(loginReq.message(), this);
ReqMsg reqMsg = EmaFactory.createReqMsg();
ommConsumer.registerClient(reqMsg.domainType(EmaRdm.MMT_DIRECTORY).serviceName("DDS_TRCE"), this);
ommConsumerCreateTime = System.currentTimeMillis();
}
}0 -
0
Categories
- All Categories
- 3 Polls
- 6 AHS
- 36 Alpha
- 166 App Studio
- 6 Block Chain
- 4 Bot Platform
- 18 Connected Risk APIs
- 47 Data Fusion
- 34 Data Model Discovery
- 685 Datastream
- 1.4K DSS
- 615 Eikon COM
- 5.2K Eikon Data APIs
- 10 Electronic Trading
- Generic FIX
- 7 Local Bank Node API
- 3 Trading API
- 2.9K Elektron
- 1.4K EMA
- 252 ETA
- 556 WebSocket API
- 38 FX Venues
- 14 FX Market Data
- 1 FX Post Trade
- 1 FX Trading - Matching
- 12 FX Trading – RFQ Maker
- 5 Intelligent Tagging
- 2 Legal One
- 23 Messenger Bot
- 3 Messenger Side by Side
- 9 ONESOURCE
- 7 Indirect Tax
- 60 Open Calais
- 275 Open PermID
- 44 Entity Search
- 2 Org ID
- 1 PAM
- PAM - Logging
- 6 Product Insight
- Project Tracking
- ProView
- ProView Internal
- 22 RDMS
- 1.9K Refinitiv Data Platform
- 652 Refinitiv Data Platform Libraries
- 4 LSEG Due Diligence
- LSEG Due Diligence Portal API
- 4 Refinitiv Due Dilligence Centre
- Rose's Space
- 1.2K Screening
- 18 Qual-ID API
- 13 Screening Deployed
- 23 Screening Online
- 12 World-Check Customer Risk Screener
- 1K World-Check One
- 46 World-Check One Zero Footprint
- 45 Side by Side Integration API
- 2 Test Space
- 3 Thomson One Smart
- 10 TR Knowledge Graph
- 151 Transactions
- 143 REDI API
- 1.8K TREP APIs
- 4 CAT
- 27 DACS Station
- 121 Open DACS
- 1.1K RFA
- 104 UPA
- 193 TREP Infrastructure
- 228 TRKD
- 917 TRTH
- 5 Velocity Analytics
- 9 Wealth Management Web Services
- 90 Workspace SDK
- 11 Element Framework
- 5 Grid
- 18 World-Check Data File
- 1 Yield Book Analytics
- 46 中文论坛