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<java.util.concurrent.ExecutorService> serialExecutor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
connectionRegistrationFailed(java.lang.String reason)
com.caplin.motif.datasource.Message
getQuote(com.caplin.ret.trapi.fx.execution.QuoteEvent trapiQuote)
Returns the quotecom.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 executedvoid
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 submittedvoid
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
-
-
-
-
Constructor Detail
-
BlockLifetimeEventHandler
public BlockLifetimeEventHandler(UserTradeInfo userTradeInfo, FxTradingAdapterInitialiser initialiser, BlockTradeBlotterDataProvider blotterDataProvider, BlockHandler tradeHandler, ConversionRateCurrencyPairProvider conversionRateCurrencyPairProvider, CrossCurrencyPairProvider crossCurrencyPairProvider, BlockTradePropertiesFactory blockTradePropertiesFactory, com.caplin.ret.trapi.concurrent.executor.SharedExecutorService<java.util.concurrent.ExecutorService> serialExecutor)
-
-
Method Detail
-
onTradeClosed
public void onTradeClosed()
- Specified by:
onTradeClosed
in interfacecom.caplin.generated.motif.fx.trading.rfs.RFSTradeListener
-
close
public void close()
- Overrides:
close
in classFXTradeLifetimeEventHandler<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 interfacecom.caplin.generated.motif.fx.trading.rfs.RFSTradeListener
-
onDealPickedUp
public void onDealPickedUp(com.caplin.ret.trapi.fx.execution.TradeEvent event)
- Specified by:
onDealPickedUp
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
onDealHeld
public void onDealHeld(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
- Specified by:
onDealHeld
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
onQuoteReceived
public void onQuoteReceived(com.caplin.ret.trapi.fx.execution.QuoteEvent quoteEvent)
- Specified by:
onQuoteReceived
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
onQuoteWithdrawn
public void onQuoteWithdrawn(com.caplin.ret.trapi.fx.execution.TradeEvent event)
- Specified by:
onQuoteWithdrawn
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
onQuoteExpired
public void onQuoteExpired(com.caplin.ret.trapi.fx.execution.TradeEvent event)
- Specified by:
onQuoteExpired
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
onDealSubmitError
public void onDealSubmitError(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
- Specified by:
onDealSubmitError
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
onDealLoggedError
public void onDealLoggedError(com.caplin.ret.trapi.fx.execution.TradeErrorEvent event)
- Specified by:
onDealLoggedError
in interfacecom.caplin.ret.trapi.fx.execution.MarketOrderListener
-
connectionRegistrationFailed
public void connectionRegistrationFailed(java.lang.String reason)
- Specified by:
connectionRegistrationFailed
in interfacecom.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 interfacecom.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 interfacecom.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 classFXTradeLifetimeEventHandler<com.caplin.generated.motif.fx.trading.rfs.RFSTrade>
-
tradeClosed
public void tradeClosed(com.caplin.trading.Trade trade)
- Specified by:
tradeClosed
in interfacecom.caplin.motif.datasource.CloseableTradeListener
- Overrides:
tradeClosed
in classFXTradeLifetimeEventHandler<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 interfacecom.caplin.trading.TradeListener
- Throws:
com.caplin.trading.TradeException
-
receiveInvalidTransitionEvent
public void receiveInvalidTransitionEvent(com.caplin.trading.InvalidTransitionEvent event)
- Specified by:
receiveInvalidTransitionEvent
in interfacecom.caplin.generated.motif.fx.trading.rfs.RFSTradeListener
- Specified by:
receiveInvalidTransitionEvent
in interfacecom.caplin.trading.TradeListener
-
receiveInvalidFieldsEvent
public void receiveInvalidFieldsEvent(com.caplin.trading.InvalidFieldsEvent event)
- Specified by:
receiveInvalidFieldsEvent
in interfacecom.caplin.generated.motif.fx.trading.rfs.RFSTradeListener
- Specified by:
receiveInvalidFieldsEvent
in interfacecom.caplin.trading.TradeListener
-
isSwap
public boolean isSwap()
- Specified by:
isSwap
in classAbstractRFSLifetimeEventHandler
-
-