Discover Refinitiv
MyRefinitiv Refinitiv Perspectives Careers
Created with Sketch.
All APIs Questions & Answers  Register |  Login
Ask a question
  • Questions
  • Tags
  • Badges
  • Unanswered
Search:
  • Home /
  • Elektron /
  • ETA /
avatar image
Question by Paul.Wuethrich2 · Jan 04 at 05:55 PM · javaeta-apirccreactor

Java ETA Reactor Programming model for managing RCC Channel A & B hosts

What is the recommended reactor-to-refinitiv host model when building a client side contributor for RCC via the Java-based ETA/Reactor API:

1. Create a single reactor and invoke connect for each channel even though channel A & B are on different Refinitiv hosts?

2. Create a reactor for each channel since they're connecting to different hosts?

The reason for the question is that we're trying to understand some run-time session management issues whereby:

-If we see start to see latency related problems our application is able to seamlessly switch from sending data from one channel (host A) to another channel (host B)

-However, if we run into session management issues whereby we receive either a CLOSED_RECOVER stream state (value = 3) or a CLOSED stream state (value = 4); it seems like we are NEVER able to switch flow from one channel to another and the entire reactor has to be shutdown and recreated. Is this expected or are missing something in our implementation of the API?

People who like this

0 Show 0
Comment
10 |1500 characters needed characters left characters exceeded
▼
  • Viewable by all users
  • Viewable by moderators
  • Viewable by moderators and the original poster
  • Advanced visibility
Viewable by all users

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

3 Replies

  • Sort: 
avatar image
REFINITIV
Best Answer
Answer by Jirapongse · Jan 12 at 04:51 AM

@Paul.Wuethrich2

I found that ETA Reactor will not recover CLOSED and CLOSED_RECOVER streams. Therefore, the application itself needs to recover the streams.

However, ETA Reactor with the watchlist feature can recover CLOSED_RECOVER streams.

If you are an RDC named user, you can contact the RDC support team directly via Contact Premium support to investigate the issue.

Comment

People who like this

0 Show 0 · Share
10 |1500 characters needed characters left characters exceeded
▼
  • Viewable by all users
  • Viewable by moderators
  • Viewable by moderators and the original poster
  • Advanced visibility
Viewable by all users

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

avatar image
REFINITIV
Answer by Jirapongse · Jan 07 at 03:55 AM

@Paul.Wuethrich2

From the question, I assume that the application would like to connect to host A and Host B simultaneously.

Both methods are valid. An application can leverage multiple Reactor instances to scale across multiple cores and distribute their ReactorChannels as needed

I think we need to focus on the CLOSED_RECOVER stream state (value = 3) or a CLOSED stream state (value = 4). Is it the closed stream state for a login or tunnel stream?


Comment

People who like this

0 Show 0 · Share
10 |1500 characters needed characters left characters exceeded
▼
  • Viewable by all users
  • Viewable by moderators
  • Viewable by moderators and the original poster
  • Advanced visibility
Viewable by all users

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

avatar image
Answer by Paul.Wuethrich2 · Jan 07 at 03:04 PM

Thanks for the reply.

The intermittent CLOSED_RECOVER & CLOSED status messages occurring as part of contributing updates via the active tunnel stream at a steady rate.

Comment

People who like this

0 Show 0 · Share
10 |1500 characters needed characters left characters exceeded
▼
  • Viewable by all users
  • Viewable by moderators
  • Viewable by moderators and the original poster
  • Advanced visibility
Viewable by all users

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

Watch this question

Add to watch list
Add to your watch list to receive emailed updates for this question. Too many emails? Change your settings >
13 People are following this question.

Related Questions

Failed to receive notification on ADH unavailability when connection is active using java reactor api

RCC Cannot Establish VAConsumer/ini File/Config - Need RCC Login Help

ETA/UPA guidance on using Real w/RealHints

I am using java reactor API for consuming data for credit bonds . As reactor api takes care of reconnection , do we need to resubscribe for items (items are subscribed without watch list)when reconnection happens? I

what is best way to test reconnection logic using reactor api ?

  • Copyright
  • Cookie Policy
  • Privacy Statement
  • Terms of Use
  • Anonymous
  • Sign in
  • Create
  • Ask a question
  • Spaces
  • Alpha
  • App Studio
  • Block Chain
  • Bot Platform
  • Connected Risk APIs
  • DSS
  • Data Fusion
  • Data Model Discovery
  • Datastream
  • Eikon COM
  • Eikon Data APIs
  • Electronic Trading
    • Generic FIX
    • Local Bank Node API
    • Trading API
  • Elektron
    • EMA
    • ETA
    • WebSocket API
  • Intelligent Tagging
  • Legal One
  • Messenger Bot
  • Messenger Side by Side
  • ONESOURCE
    • Indirect Tax
  • Open Calais
  • Open PermID
    • Entity Search
  • Org ID
  • PAM
    • PAM - Logging
  • ProView
  • ProView Internal
  • Product Insight
  • Project Tracking
  • RDMS
  • Refinitiv Data Platform
    • Refinitiv Data Platform Libraries
  • Rose's Space
  • Screening
    • Qual-ID API
    • Screening Deployed
    • Screening Online
    • World-Check One
    • World-Check One Zero Footprint
  • Side by Side Integration API
  • TR Knowledge Graph
  • TREP APIs
    • CAT
    • DACS Station
    • Open DACS
    • RFA
    • UPA
  • TREP Infrastructure
  • TRKD
  • TRTH
  • Thomson One Smart
  • Transactions
    • REDI API
  • Velocity Analytics
  • Wealth Management Web Services
  • Workspace SDK
    • Element Framework
    • Grid
  • World-Check Data File
  • 中文论坛
  • Explore
  • Tags
  • Questions
  • Badges