com.apama.marketdata
Monitor ServerBridge


This service allows a correlator to provide access to market data that it receives from an adapter to other client correlators.

This service is used to bridge the com.apama.marketdata interface between two correlators. One correlator, connected to an adapter, acts as a server. The other correlator as a client. To perform the bridging, this monitor needs to be injected in the server correlator and an instance created by sending in the ConfigureServerSideBridge event. The two correlators must be connected to each other, and the channels in the configuration events have to match those of the engine connections.

This service will listen for depth/tick subscriptions that will have been forwarded to the server by the client. It will then setup listeners for the tick/depth events as well as the error events. When these fire, the service emits the events back to the client correlator. The service will also listen for the unsubscribe events from the client in order to destroy these listeners.

This service will also monitor the connection by using the IAFConnectionMonitor component, note that this means that the IAFStatusFaker must be running on the client correlator. Setting up instances of The IAFConnectionMonitor will normally be done by the adapter bridging configuration service. When a connection goes down, this monitor will unsubscribe to the adapter. When it comes back up, it will re-subscribe.
Since:
CMF 1.1.0
Version:
10.0
See Also:
com.apama.adapter.bridge.ConfigBridge - The adapter bridging config service will normally create instances of this bridge
com.apama.marketdata.ClientBridge - The client bridge communicates with the server bridge in another correlator.
com.apama.adapters.IAFConnectionMonitor - This bridge monitors the connection to the client correlator using this connection monitor
Routes:
com.apama.marketdata.SubscribeDepth - This service will re-subscribe to the adapter when the correlator to correlator connection comes back up
com.apama.marketdata.SubscribeTick - This service will re-subscribe to the adapter when the correlator to correlator connection comes back up
com.apama.marketdata.UnsubscribeDepth - This service will un-subscribe to the the adapter when the correlator to correlator connection goes down
com.apama.marketdata.UnsubscribeTick - This service will un-subscribe to the adapter when the correlator to correlator connection goes down
Sends:
com.apama.marketdata.Depth - The depth events forwarded to the client
com.apama.marketdata.DepthSubscriptionError - The depth error events forwarded to the client
com.apama.marketdata.Tick - The tick events forwarded to the client
com.apama.marketdata.TickSubscriptionError - The tick error events forwarded to the client
Listens:
com.apama.marketdata.ConfigureServerSideBridge - The event that creates instances of this monitor.
com.apama.marketdata.Depth - The depth events that will be forwarded to the client
com.apama.marketdata.DepthSubscriptionError - The depth error events that will be forwarded to the client
com.apama.marketdata.SubscribeDepth - This bridge listens for subscriptions from the client in order to setup the listeners that forward depth
com.apama.marketdata.SubscribeTick - This bridge listens for subscriptions from the client in order to setup the listeners that forward tick
com.apama.marketdata.Tick - The tick events that will be forwarded to the client
com.apama.marketdata.TickSubscriptionError - The tick error events that will be forwarded to the client
com.apama.marketdata.UnsubscribeDepth - This bridge listens for unsubscriptions from the client in order to destroy the listeners that forward depth
com.apama.marketdata.UnsubscribeTick - This bridge listens for unsubscriptions from the client in order to destroy the listeners that forward tick