com.caplin.motif.fx.ret.fxtrading.submission.rfs

Class RFSLifetimeEventHandler<H extends TradeTypeHandler>

java.lang.Object

com.caplin.motif.fx.ret.fxtrading.submission.FXTradeLifetimeEventHandler<com.caplin.generated.motif.fx.trading.rfs.RFSTrade>

com.caplin.motif.fx.ret.fxtrading.submission.rfs.RFSLifetimeEventHandler<H>

Type Parameters:

H - A Handler

All Implemented Interfaces:

com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener, com.caplin.motif.datasource.CloseableTradeListener, ConversionRateListener, com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.MarketOrderConnection>, com.caplin.ret.trapi.fx.execution.MarketOrderListener, com.caplin.trading.TradeListener

public class RFSLifetimeEventHandler<H extends TradeTypeHandler>
extends FXTradeLifetimeEventHandler<com.caplin.generated.motif.fx.trading.rfs.RFSTrade>
implements com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener, ConversionRateListener

Receives events throughout the lifetime of an RFS trade.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	L1_PREFIX
static java.lang.String	L2_PREFIX

Constructor Summary

Constructors

Constructor and Description
RFSLifetimeEventHandler(FxTradingAdapterInitialiser adapterInitialiser, UserTradeInfo userTradeInfo, H tradeHandler, AbstractBlotterDataProvider<com.caplin.generated.motif.fx.trading.rfs.RFSTrade> blotterProvider, ExecutionFactory executionFactory, ConversionRateCurrencyPairProvider conversionRateCurrencyPairProvider, CrossCurrencyPairProvider crossCurrencyPairProvider)

Method Summary

Modifier and Type	Method and Description
void	_connectionAvailable(com.caplin.ret.trapi.connection.MarketOrderConnection connection)
void	connectionAvailable(com.caplin.ret.trapi.connection.MarketOrderConnection connection)
void	connectionRegistrationFailed(java.lang.String reason)
com.caplin.ret.trapi.fx.execution.TradeAcceptanceBuilder	createFxTradeAcceptBuilder()
com.caplin.ret.trapi.fx.execution.TradeAcceptanceBuilder	createFxTradeAcceptBuilder(int priceVersion)
com.caplin.motif.datasource.Message	getQuote(com.caplin.ret.trapi.fx.execution.QuoteEvent rfsQuote)
com.caplin.ret.trapi.fx.execution.MarketOrder	getTrapiTrade()
boolean	isQuoteValid(RFSQuote currentQuote, com.caplin.generated.motif.fx.trading.rfs.events.client.ExecuteTradeEvent event)
void	onClientClose(com.caplin.generated.motif.fx.trading.rfs.events.client.ClientCloseTradeEvent clientCloseTradeEvent)
void	onDealHeld(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
void	onDealLogged(com.caplin.ret.trapi.fx.execution.QuoteEvent quote)
void	onDealLoggedError(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
void	onDealPickedUp(com.caplin.ret.trapi.fx.execution.TradeEvent event)
void	onDealSubmitError(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
void	onDealSubmitted(com.caplin.ret.trapi.fx.execution.TradeEvent event)
void	onExecute(com.caplin.generated.motif.fx.trading.rfs.events.client.ExecuteTradeEvent event)
void	onFailure()
void	onQuoteDenied(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
void	onQuoteExpired(com.caplin.ret.trapi.fx.execution.TradeEvent event)
void	onQuoteReceived(com.caplin.ret.trapi.fx.execution.QuoteEvent quoteEvent)
void	onQuoteTimerUpdate(com.caplin.ret.trapi.fx.execution.QuoteTimerEvent event)
void	onQuoteWithdrawn(com.caplin.ret.trapi.fx.execution.TradeEvent event)
void	onRateUpdate(java.lang.String bidRate, java.lang.String askRate)
void	onSubmit(com.caplin.generated.motif.fx.trading.rfs.events.client.SubmitTradeEvent submitEvent)
void	onTradeClosed()
void	receiveEvent(com.caplin.trading.TradeEvent event)
void	receiveInvalidFieldsEvent(com.caplin.trading.InvalidFieldsEvent event)
void	receiveInvalidTransitionEvent(com.caplin.trading.InvalidTransitionEvent event)
com.caplin.ret.trapi.fx.execution.MarketOrder	setUpTrade(com.caplin.ret.trapi.fx.execution.TradingService tradingService, com.caplin.ret.trapi.fx.execution.AccountService accountService)

Methods inherited from class com.caplin.motif.fx.ret.fxtrading.submission.FXTradeLifetimeEventHandler

close, tradeClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

onAcceptWarning, onError, onRejectWarning, onResubmit, onUnhandledTradeEvent

Field Detail

L1_PREFIX

public static final java.lang.String L1_PREFIX

See Also:

Constant Field Values

L2_PREFIX

public static final java.lang.String L2_PREFIX

See Also:

Constant Field Values

Constructor Detail

RFSLifetimeEventHandler

public RFSLifetimeEventHandler(FxTradingAdapterInitialiser adapterInitialiser,
                               UserTradeInfo userTradeInfo,
                               H tradeHandler,
                               AbstractBlotterDataProvider<com.caplin.generated.motif.fx.trading.rfs.RFSTrade> blotterProvider,
                               ExecutionFactory executionFactory,
                               ConversionRateCurrencyPairProvider conversionRateCurrencyPairProvider,
                               CrossCurrencyPairProvider crossCurrencyPairProvider)

Method Detail

getTrapiTrade

public com.caplin.ret.trapi.fx.execution.MarketOrder getTrapiTrade()

Specified by:

getTrapiTrade in class FXTradeLifetimeEventHandler<com.caplin.generated.motif.fx.trading.rfs.RFSTrade>

isQuoteValid

public boolean isQuoteValid(RFSQuote currentQuote,
                            com.caplin.generated.motif.fx.trading.rfs.events.client.ExecuteTradeEvent event)

onDealPickedUp

public void onDealPickedUp(com.caplin.ret.trapi.fx.execution.TradeEvent event)

Specified by:

onDealPickedUp in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onDealHeld

public void onDealHeld(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)

Specified by:

onDealHeld in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onDealLogged

public void onDealLogged(com.caplin.ret.trapi.fx.execution.QuoteEvent quote)

Specified by:

onDealLogged in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onQuoteReceived

public void onQuoteReceived(com.caplin.ret.trapi.fx.execution.QuoteEvent quoteEvent)

Specified by:

onQuoteReceived in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onQuoteWithdrawn

public void onQuoteWithdrawn(com.caplin.ret.trapi.fx.execution.TradeEvent event)

Specified by:

onQuoteWithdrawn in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onQuoteExpired

public void onQuoteExpired(com.caplin.ret.trapi.fx.execution.TradeEvent event)

Specified by:

onQuoteExpired in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onQuoteDenied

public void onQuoteDenied(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)

Specified by:

onQuoteDenied in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onDealSubmitError

public void onDealSubmitError(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)

Specified by:

onDealSubmitError in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onDealLoggedError

public void onDealLoggedError(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)

Specified by:

onDealLoggedError in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

onQuoteTimerUpdate

public void onQuoteTimerUpdate(com.caplin.ret.trapi.fx.execution.QuoteTimerEvent event)

Specified by:

onQuoteTimerUpdate in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener

connectionRegistrationFailed

public void connectionRegistrationFailed(java.lang.String reason)

Specified by:

connectionRegistrationFailed in interface com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.MarketOrderConnection>

_connectionAvailable

public void _connectionAvailable(com.caplin.ret.trapi.connection.MarketOrderConnection connection)

createFxTradeAcceptBuilder

public com.caplin.ret.trapi.fx.execution.TradeAcceptanceBuilder createFxTradeAcceptBuilder(int priceVersion)

onExecute

public void onExecute(com.caplin.generated.motif.fx.trading.rfs.events.client.ExecuteTradeEvent event)

Specified by:

onExecute in interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

onClientClose

public void onClientClose(com.caplin.generated.motif.fx.trading.rfs.events.client.ClientCloseTradeEvent clientCloseTradeEvent)

Specified by:

onClientClose in interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

onSubmit

public void onSubmit(com.caplin.generated.motif.fx.trading.rfs.events.client.SubmitTradeEvent submitEvent)

Specified by:

onSubmit in interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

connectionAvailable

public void connectionAvailable(com.caplin.ret.trapi.connection.MarketOrderConnection connection)

Specified by:

connectionAvailable in interface com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.MarketOrderConnection>

onTradeClosed

public void onTradeClosed()

Specified by:

onTradeClosed in interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

receiveEvent

public void receiveEvent(com.caplin.trading.TradeEvent event)
                  throws com.caplin.trading.TradeException

Specified by:

receiveEvent in interface com.caplin.trading.TradeListener

Throws:

com.caplin.trading.TradeException

receiveInvalidTransitionEvent

public void receiveInvalidTransitionEvent(com.caplin.trading.InvalidTransitionEvent event)

Specified by:

receiveInvalidTransitionEvent in interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

Specified by:

receiveInvalidTransitionEvent in interface com.caplin.trading.TradeListener

receiveInvalidFieldsEvent

public void receiveInvalidFieldsEvent(com.caplin.trading.InvalidFieldsEvent event)

Specified by:

receiveInvalidFieldsEvent in interface com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

Specified by:

receiveInvalidFieldsEvent in interface com.caplin.trading.TradeListener

onRateUpdate

public void onRateUpdate(java.lang.String bidRate,
                         java.lang.String askRate)

Specified by:

onRateUpdate in interface ConversionRateListener

onFailure

public void onFailure()

Specified by:

onFailure in interface ConversionRateListener

setUpTrade

public com.caplin.ret.trapi.fx.execution.MarketOrder setUpTrade(com.caplin.ret.trapi.fx.execution.TradingService tradingService,
                                                                com.caplin.ret.trapi.fx.execution.AccountService accountService)
                                                         throws java.lang.Exception

Throws:

java.lang.Exception

getQuote

public com.caplin.motif.datasource.Message getQuote(com.caplin.ret.trapi.fx.execution.QuoteEvent rfsQuote)
                                             throws QuoteCreationException

Throws:

QuoteCreationException

createFxTradeAcceptBuilder

public com.caplin.ret.trapi.fx.execution.TradeAcceptanceBuilder createFxTradeAcceptBuilder()

onDealSubmitted

public void onDealSubmitted(com.caplin.ret.trapi.fx.execution.TradeEvent event)

Specified by:

onDealSubmitted in interface com.caplin.ret.trapi.fx.execution.MarketOrderListener