Class RETSubscriptionListener<T extends com.caplin.motif.fx.rates.RateSubjectInfo>
java.lang.Object
com.caplin.motif.fx.ret.pricing.provider.RETSubscriptionListener<T>
- All Implemented Interfaces:
com.caplin.ret.trapi.rates.SubscriptionListener
public class RETSubscriptionListener<T extends com.caplin.motif.fx.rates.RateSubjectInfo>
extends Object
implements com.caplin.ret.trapi.rates.SubscriptionListener
-
Constructor Summary
ConstructorsConstructorDescriptionRETSubscriptionListener
(T subjectInfo, com.caplin.motif.fx.rates.FXQuotePublisher publisher, com.caplin.ret.trapi.admin.AdminService adminService, PricingDataProvider<T> pricingProvider, ExecutorService singleThreadedExecutor, String adapterName, io.micrometer.core.instrument.Counter updateCounter) -
Method Summary
Modifier and TypeMethodDescriptionvoid
onForwardRateUpdate
(com.caplin.ret.trapi.rates.ForwardQuote forwardQuote) void
void
void
onSpotRateUpdate
(com.caplin.ret.trapi.rates.SpotQuote spotQuote) void
onSubscribeFail
(String reason, int code) void
-
Constructor Details
-
RETSubscriptionListener
public RETSubscriptionListener(T subjectInfo, com.caplin.motif.fx.rates.FXQuotePublisher publisher, com.caplin.ret.trapi.admin.AdminService adminService, PricingDataProvider<T> pricingProvider, ExecutorService singleThreadedExecutor, String adapterName, io.micrometer.core.instrument.Counter updateCounter)
-
-
Method Details
-
onSubscribePass
public void onSubscribePass()- Specified by:
onSubscribePass
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-
onSubscribeFail
- Specified by:
onSubscribeFail
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-
onSpotRateUpdate
public void onSpotRateUpdate(com.caplin.ret.trapi.rates.SpotQuote spotQuote) - Specified by:
onSpotRateUpdate
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-
onForwardRateUpdate
public void onForwardRateUpdate(com.caplin.ret.trapi.rates.ForwardQuote forwardQuote) - Specified by:
onForwardRateUpdate
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-
onInstrumentStale
public void onInstrumentStale()- Specified by:
onInstrumentStale
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-
onInstrumentNotStale
public void onInstrumentNotStale()- Specified by:
onInstrumentNotStale
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-