You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In order to have separate traffic back to Gateways then the Service needs separate endpoints for them. This can be done in different ways including configuration, a discovery service, or by using the Image.sourceIdentity() which can be picked up when a onAvailableImage() callback is triggered.
The text was updated successfully, but these errors were encountered:
For the request traffic to the same channel and stream id, the Header.sessionId() can be used to match request sources with responses previously matched up with the onAvailableImage() callbacks.
The addService and addGateway APIs in Helios class shall be modified to take as parameter just the input stream where the Aeron subscription takes place; the output streams shall be added to the Service or Gateway using the Aeron onAvailableImage() callback. The Service and Gateway implementations shall be modified to create output ring buffers and their processors accordingly, based on Image callback information (sourceIdentity, streamId, sessionId...).
…ive data messages
Added MMB Startup message to address application-level association between GWs and SVCs
Handled MMB Startup/Shutdown messages to address application-level association between GWs and SVCs as per issues #9 and #15
Changed some thread running variables to use volatile instead of atomic primitives
Added initial status counters support
Refactored report classes and functions
Added/modified unit and perf tests
In order to have separate traffic back to Gateways then the Service needs separate endpoints for them. This can be done in different ways including configuration, a discovery service, or by using the Image.sourceIdentity() which can be picked up when a onAvailableImage() callback is triggered.
The text was updated successfully, but these errors were encountered: