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 java.lang.Object implements com.caplin.ret.trapi.rates.SubscriptionListener
-
-
Constructor Summary
Constructors Constructor Description RETSubscriptionListener(T subjectInfo, com.caplin.motif.fx.rates.FXQuotePublisher publisher, com.caplin.ret.trapi.admin.AdminService adminService, PricingDataProvider<T> pricingProvider, java.util.concurrent.ExecutorService singleThreadedExecutor, java.lang.String adapterName, io.micrometer.core.instrument.Counter updateCounter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onForwardRateUpdate(com.caplin.ret.trapi.rates.ForwardQuote forwardQuote)
void
onInstrumentNotStale()
void
onInstrumentStale()
void
onSpotRateUpdate(com.caplin.ret.trapi.rates.SpotQuote spotQuote)
void
onSubscribeFail(java.lang.String reason, int code)
void
onSubscribePass()
-
-
-
Constructor Detail
-
RETSubscriptionListener
public RETSubscriptionListener(T subjectInfo, com.caplin.motif.fx.rates.FXQuotePublisher publisher, com.caplin.ret.trapi.admin.AdminService adminService, PricingDataProvider<T> pricingProvider, java.util.concurrent.ExecutorService singleThreadedExecutor, java.lang.String adapterName, io.micrometer.core.instrument.Counter updateCounter)
-
-
Method Detail
-
onSubscribePass
public void onSubscribePass()
- Specified by:
onSubscribePass
in interfacecom.caplin.ret.trapi.rates.SubscriptionListener
-
onSubscribeFail
public void onSubscribeFail(java.lang.String reason, int code)
- 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
-
-