com.caplin.motif.fx.rates

Class FXRatesAdapter

java.lang.Object

com.caplin.motif.datasource.CachedAdapter

com.caplin.motif.fx.rates.FXRatesAdapter

public class FXRatesAdapter
extends CachedAdapter

An FXRatesAdapter services rate streaming for ESP, SPOT, FORWARD and SWAP rates. The adapter also supports streaming prices for broken dates.

Typically, an FXRatesAdapter will be setup as follows:

 FXRatesAdapter adapter = new FXRatesAdapter(dataSource);
 

Constructor Summary

Constructors

Constructor and Description
FXRatesAdapter(com.caplin.datasource.DataSource dataSource) Constructs an FXRatesAdapter that will utilise the specified DataSource and its configuration for communication with the motif.

Method Summary

Modifier and Type	Method and Description
FXQuotePublisher	createMetalQuotePublisher(CachedDataProvider<? extends MetalSubjectInfo> provider) Creates an FXQuotePublisher that is able to respond to messages received on the CachedDataProvider that is passed in.
FXQuotePublisher	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	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	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	createQuotePublisher(CachedDataProvider<? extends FXSubjectInfo> provider) Creates an FXQuotePublisher that is able to respond to messages received on the CachedDataProvider that is passed in.
FXQuotePublisher	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	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	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.

Methods inherited from class com.caplin.motif.datasource.CachedAdapter

clearCache, createActivePublisher, createActivePublisher, createActivePublisher, createActivePublisher

Methods inherited from class java.lang.Object

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

Constructor Detail

FXRatesAdapter

public FXRatesAdapter(com.caplin.datasource.DataSource dataSource)

Constructs an FXRatesAdapter that will utilise the specified DataSource and its configuration for communication with the motif.

Parameters:

dataSource - The DataSource that will be used to receive requests for ESP, SPOT, FORWARD and SWAP rates. As well as requests for prices on Broken Dates.

Method Detail

createQuotePublisher

public FXQuotePublisher 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.

Parameters:

provider - the CachedDataProvider that will receive the rate requests

subjectParser - the parser that will parse FX 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 FXQuotePublisher.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.

Returns:

the FXQuotePublisher able to send quotes containing rates

createQuotePublisher

public FXQuotePublisher 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.

Parameters:

provider - the CachedDataProvider that will receive the rate requests

subjectParser - the parser that will parse FX rate subject requests into an object representation of the request.

Returns:

the FXQuotePublisher able to rate quotes containing rates

createQuotePublisher

public FXQuotePublisher 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.

Parameters:

provider - the CachedDataProvider that will receive the rate requests

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 FXQuotePublisher.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.

Returns:

the FXQuotePublisher able to send quotes containing rates

createQuotePublisher

public FXQuotePublisher createQuotePublisher(CachedDataProvider<? extends FXSubjectInfo> provider)

Creates an FXQuotePublisher that is able to respond to messages received on the CachedDataProvider that is passed in.

Parameters:

provider - the CachedDataProvider that will receive the rate requests

Returns:

the FXQuotePublisher able to send quotes containing rates

createMetalQuotePublisher

public FXQuotePublisher 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.

Parameters:

provider - the CachedDataProvider that will receive the metal requests

subjectParser - the parser that will parse metal subject requests into an object representation of the request.

sendDiscardAfterError - If set to TRUE, a discard message will be triggered after a NotFound or Unavailable message is sent from the publisher.

Returns:

the FXQuotePublisher able to send quotes for metals

createMetalQuotePublisher

public FXQuotePublisher 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.

Parameters:

provider - the CachedDataProvider that will receive the metal requests

subjectParser - the parser that will parse metal subject requests into an object representation of the request.

Returns:

the FXQuotePublisher able to send quotes for metals

createMetalQuotePublisher

public FXQuotePublisher 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.

Parameters:

provider - the CachedDataProvider that will receive the metal requests

sendDiscardAfterError - If set to TRUE, a discard message will be triggered after a NotFound or Unavailable message is sent from the publisher.

Returns:

the FXQuotePublisher able to send quotes for metals

createMetalQuotePublisher

public FXQuotePublisher createMetalQuotePublisher(CachedDataProvider<? extends MetalSubjectInfo> provider)

Creates an FXQuotePublisher that is able to respond to messages received on the CachedDataProvider that is passed in.

Parameters:

provider - the CachedDataProvider that will receive the metal requests

Returns:

the FXQuotePublisher able to send quotes for metals