Package | Description |
---|---|
com.caplin.motif.datasource |
Extensions to the DataSource for Java library.
|
com.caplin.motif.fx.rates |
Classes and interfaces that relate to streaming FX rates.
|
Modifier and Type | Method and Description |
---|---|
CachedPublisher |
CachedAdapter.createActivePublisher(com.caplin.datasource.namespace.Namespace namespace,
CachedDataProvider<?> dataProvider,
SubjectParser<?> parser)
Creates an
ActivePublisher that will
publish messages on the specified Namespace.
This method uses a subject parser which allows subjects to be parsed into
meaningful request objects, for example the FXSubjectInfo . |
CachedPublisher |
CachedAdapter.createActivePublisher(com.caplin.datasource.namespace.Namespace namespace,
CachedDataProvider<?> dataProvider,
SubjectParser<?> parser,
boolean sendDiscardAfterError)
Creates an
ActivePublisher that will
publish messages on the specified Namespace.
This method uses a subject parser which allows subjects to be parsed into
meaningful request objects, for example the FXSubjectInfo |
Modifier and Type | Method and Description |
---|---|
FXQuotePublisher |
FXRatesAdapter.createMetalQuotePublisher(CachedDataProvider<? extends MetalSubjectInfo> provider)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createMetalQuotePublisher(CachedDataProvider<? extends MetalSubjectInfo> provider,
boolean sendDiscardAfterError)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createMetalQuotePublisher(CachedDataProvider<? extends MetalSubjectInfo> provider,
SubjectParser<? extends MetalSubjectInfo> subjectParser)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createMetalQuotePublisher(CachedDataProvider<? extends MetalSubjectInfo> provider,
SubjectParser<? extends MetalSubjectInfo> subjectParser,
boolean sendDiscardAfterError)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createQuotePublisher(CachedDataProvider<? extends FXSubjectInfo> provider)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createQuotePublisher(CachedDataProvider<? extends FXSubjectInfo> provider,
boolean sendDiscardAfterError)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createQuotePublisher(CachedDataProvider<? extends FXSubjectInfo> provider,
SubjectParser<? extends FXSubjectInfo> subjectParser)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
FXQuotePublisher |
FXRatesAdapter.createQuotePublisher(CachedDataProvider<? extends FXSubjectInfo> provider,
SubjectParser<? extends FXSubjectInfo> subjectParser,
boolean sendDiscardAfterError)
Creates an FXQuotePublisher that is able to respond to messages
received on the CachedDataProvider that is passed in.
|
Copyright © 2015 Caplin Systems.