@Beta public class MMRatesAdapter extends CachedAdapter
An MMRatesAdapter services rate streaming for ESP rates. The adapter also supports streaming prices for broken dates.
Typically, an MMRatesAdapter will be setup as follows:
MMRatesAdapter adapter = new MMRatesAdapter(dataSource);BETA - May change significantly.
Constructor and Description |
---|
MMRatesAdapter(com.caplin.datasource.DataSource dataSource)
Constructs an MMRatesAdapter that will utilise the specified
DataSource and its configuration for communication with the motif.
|
Modifier and Type | Method and Description |
---|---|
SubjectMessagePublisher<RateSubjectInfo> |
createQuotePublisher(String namespace,
CachedDataProvider<RateSubjectInfo> provider)
Creates an MMQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
SubjectMessagePublisher<RateSubjectInfo> |
createQuotePublisher(String namespace,
CachedDataProvider<RateSubjectInfo> provider,
boolean sendDiscardAfterError)
Creates an MMQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
SubjectMessagePublisher<RateSubjectInfo> |
createQuotePublisherWithSubjectParser(String namespace,
CachedDataProvider<RateSubjectInfo> provider,
RateSubjectParser subjectParser)
Creates an MMQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
SubjectMessagePublisher<RateSubjectInfo> |
createQuotePublisherWithSubjectParser(String namespace,
CachedDataProvider<RateSubjectInfo> provider,
RateSubjectParser subjectParser,
boolean sendDiscardAfterError)
Creates an MMQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
clearCache, createActivePublisher, createActivePublisher, createCachedPublisher, createCachedPublisher, createCachedPublisher, createCachedPublisher
public MMRatesAdapter(com.caplin.datasource.DataSource dataSource)
dataSource
- The DataSource that will be used to receive requests
for ESP rates. As well as
requests for prices on Broken Dates.public SubjectMessagePublisher<RateSubjectInfo> createQuotePublisher(String namespace, CachedDataProvider<RateSubjectInfo> provider, boolean sendDiscardAfterError)
namespace
- the namespace to provide rates for, defaults are defined in RateSubjectNamespacing.DefaultNamespaces
provider
- the CachedDataProvider that will receive the rate requestssendDiscardAfterError
- If set to TRUE, your CachedDataProvider will receive an
immediate callback on the CachedDataProvider.onDiscard(SubjectInfo)
method
after you publish a failure message by calling SubjectMessagePublisher.sendNotFound(SubjectInfo)
.
This can be useful if you want to use the same code path to clear a cache (for example) whether a subscription
is ended by the client discarding it or the back end you are integrating with no longer providing the data.public SubjectMessagePublisher<RateSubjectInfo> createQuotePublisher(String namespace, CachedDataProvider<RateSubjectInfo> provider)
namespace
- the namespace to provide rates for, defaults are defined in RateSubjectNamespacing.DefaultNamespaces
provider
- the CachedDataProvider that will receive the rate requestspublic SubjectMessagePublisher<RateSubjectInfo> createQuotePublisherWithSubjectParser(String namespace, CachedDataProvider<RateSubjectInfo> provider, RateSubjectParser subjectParser)
namespace
- the namespace to provide rates for, defaults are defined in RateSubjectNamespacing.DefaultNamespaces
provider
- the CachedDataProvider that will receive the rate requestssubjectParser
- the parser that will parse rate subject requests into an object representation of the request.public SubjectMessagePublisher<RateSubjectInfo> createQuotePublisherWithSubjectParser(String namespace, CachedDataProvider<RateSubjectInfo> provider, RateSubjectParser subjectParser, boolean sendDiscardAfterError)
namespace
- the namespace to provide rates for, defaults are defined in RateSubjectNamespacing.DefaultNamespaces
provider
- the CachedDataProvider that will receive the rate requestssubjectParser
- the parser that will parse rate subject requests into an object representation of the request.sendDiscardAfterError
- If set to TRUE, your CachedDataProvider will receive an
immediate callback on the CachedDataProvider.onDiscard(SubjectInfo)
method
after you publish a failure message by calling SubjectMessagePublisher.sendNotFound(SubjectInfo)
.
This can be useful if you want to use the same code path to clear a cache (for example) whether a subscription
is ended by the client discarding it or the back end you are integrating with no longer providing the data.Copyright © 2018 Caplin Systems.