question

Upvotes
Accepted
Paul.Wuethrich2 avatar image
20 ●7 ●8 ●11

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?

javaeta-apirccreactor
icon clock
10 |1500

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

raksina.samasiri avatar image   raksina.samasiri

hi @Paul.Wuethrich2

Thank you for your participation in the forum. Is the reply below satisfactory in resolving your query?
If so please can you click the 'Accept' text next to the appropriate reply? This will guide all community members who have a similar question or could you provide the information required for further investigation, please?

Thanks,
AHS

zoya faberov avatar image   zoya faberov

Hello @Paul.Wuethrich2 ,

Thank you for your participation in the forum.

Is the reply below satisfactory in resolving your query?

If yes, please click the 'Accept' text next to the appropriate reply. This will guide all community members who have a similar question. Otherwise please post again offering further insight into your question.

Thanks,

-AHS

Shadab Hussain avatar image   Shadab Hussain

Hi @Paul.Wuethrich2 ,

Please be informed that a reply has been verified as correct in answering the question, and has been marked as such.


Thanks,

AHS

3 Answers

· Write an Answer
Upvotes
Accepted
Jirapongse avatar image
79.2k ●251 ●52 ●74

@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.

icon clock
10 |1500

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

Upvotes
Jirapongse avatar image
79.2k ●251 ●52 ●74

@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?


icon clock
10 |1500

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

Upvotes
Paul.Wuethrich2 avatar image
20 ●7 ●8 ●11

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.

icon clock
10 |1500

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

Write an Answer

Hint: Notify or tag a user in this post by typing @username.

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