Package com.caplin.motif.fx.ret.pricing.provider

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

Constructors

Constructor	Description
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 Summary

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(String reason, int code)
void	onSubscribePass()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface com.caplin.ret.trapi.rates.SubscriptionListener

onSubscribeFail

public void onSubscribeFail(String reason,
 int code)

Specified by:

onSubscribeFail in interface com.caplin.ret.trapi.rates.SubscriptionListener

onSpotRateUpdate

public void onSpotRateUpdate(com.caplin.ret.trapi.rates.SpotQuote spotQuote)

Specified by:

onSpotRateUpdate in interface com.caplin.ret.trapi.rates.SubscriptionListener

onForwardRateUpdate

public void onForwardRateUpdate(com.caplin.ret.trapi.rates.ForwardQuote forwardQuote)

Specified by:

onForwardRateUpdate in interface com.caplin.ret.trapi.rates.SubscriptionListener

onInstrumentStale

public void onInstrumentStale()

Specified by:

onInstrumentStale in interface com.caplin.ret.trapi.rates.SubscriptionListener

onInstrumentNotStale

public void onInstrumentNotStale()

Specified by:

onInstrumentNotStale in interface com.caplin.ret.trapi.rates.SubscriptionListener