Package com.caplin.motif.fx.ret.fxtrading.submission.block

Class BlockLifetimeEventHandler

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

com.caplin.motif.fx.ret.fxtrading.submission.block.BlockLifetimeEventHandler

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 BlockLifetimeEventHandler
extends AbstractRFSLifetimeEventHandler
implements com.caplin.generated.motif.fx.trading.rfs.RFSTradeListener

Nested Class Summary

Nested classes/interfaces inherited from class com.caplin.motif.fx.ret.fxtrading.submission.rfs.AbstractRFSLifetimeEventHandler

AbstractRFSLifetimeEventHandler.TradeState

Constructor Summary

Constructors

Constructor

Description

BlockLifetimeEventHandler(UserTradeInfo userTradeInfo, FxTradingAdapterInitialiser initialiser, BlockTradeBlotterDataProvider blotterDataProvider, BlockHandler tradeHandler, ConversionRateCurrencyPairProvider conversionRateCurrencyPairProvider, CrossCurrencyPairProvider crossCurrencyPairProvider, BlockTradePropertiesFactory blockTradePropertiesFactory, com.caplin.ret.trapi.concurrent.executor.SharedExecutorService<ExecutorService> serialExecutor)

Method Summary

Modifier and Type	Method	Description
void	close()
void	connectionRegistrationFailed(String reason)
com.caplin.motif.datasource.Message	getQuote(com.caplin.ret.trapi.fx.execution.QuoteEvent trapiQuote)	Returns the quote
com.caplin.ret.trapi.fx.execution.MarketOrder	getTrapiTrade()
boolean	isSwap()
void	onClientClose(com.caplin.generated.motif.fx.trading.rfs.events.client.ClientCloseTradeEvent clientCloseTradeEvent)
void	onDealHeld(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
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	onExecute(com.caplin.generated.motif.fx.trading.rfs.events.client.ExecuteTradeEvent originalEvent)	Triggered when a block trade is executed
void	onQuoteExpired(com.caplin.ret.trapi.fx.execution.TradeEvent event)
void	onQuoteReceived(com.caplin.ret.trapi.fx.execution.QuoteEvent quoteEvent)
void	onQuoteWithdrawn(com.caplin.ret.trapi.fx.execution.TradeEvent event)
void	onSubmit(com.caplin.generated.motif.fx.trading.rfs.events.client.SubmitTradeEvent originalEvent)	Triggered when a block trade is submitted
void	onTradeClosed()
void	receiveEvent(com.caplin.trading.TradeEvent event)
void	receiveInvalidFieldsEvent(com.caplin.trading.InvalidFieldsEvent event)
void	receiveInvalidTransitionEvent(com.caplin.trading.InvalidTransitionEvent event)
void	tradeClosed(com.caplin.trading.Trade trade)

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

connectionAvailable, onConversionRateFailure, onConversionRateUpdate, onDealSubmitted, onQuoteDenied, onQuoteTimerUpdate

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

onDealLogged

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

Constructor Details

BlockLifetimeEventHandler

public BlockLifetimeEventHandler(UserTradeInfo userTradeInfo,
 FxTradingAdapterInitialiser initialiser,
 BlockTradeBlotterDataProvider blotterDataProvider,
 BlockHandler tradeHandler,
 ConversionRateCurrencyPairProvider conversionRateCurrencyPairProvider,
 CrossCurrencyPairProvider crossCurrencyPairProvider,
 BlockTradePropertiesFactory blockTradePropertiesFactory,
 com.caplin.ret.trapi.concurrent.executor.SharedExecutorService<ExecutorService> serialExecutor)

Method Details

onTradeClosed

public void onTradeClosed()

Specified by:

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

close

public void close()

Overrides:

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

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

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

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

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

connectionRegistrationFailed

public void connectionRegistrationFailed(String reason)

Specified by:

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

onSubmit

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

Triggered when a block trade is submitted

Specified by:

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

Parameters:

originalEvent - the BlockTradeSubmitEvent

onExecute

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

Triggered when a block trade is executed

Specified by:

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

Parameters:

originalEvent - the BlockTradeExecuteEvent

getQuote

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

Returns the quote

Parameters:

trapiQuote - the quote from RET

Returns:

the FXQuote

Throws:

QuoteCreationException

getTrapiTrade

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

Specified by:

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

tradeClosed

public void tradeClosed(com.caplin.trading.Trade trade)

Specified by:

tradeClosed in interface com.caplin.motif.datasource.CloseableTradeListener

Overrides:

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

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

isSwap

public boolean isSwap()

Specified by:

isSwap in class AbstractRFSLifetimeEventHandler