public class OpenOrdersListener
extends java.lang.Object
implements com.caplin.ret.trapi.fx.order.listener.OrderListener
OpenOrdersListener has two groups of methods which handle individual updates and 'bulk' updates. LOMS is responsible for passing us either individual or batch updates.
The correctness of update ordering is maintained through the use of a single thread executor. Bulk updates in contrast are processed in parallel. Presumably the assumption in the original design was that the data will be old and is unlikely to be refreshed during processing.
OpenOrdersListener collaborates with the BlotterDataExtractor to fan out order updates to the correct blotter.
-(persession) alive as long as the user is subscribed to any blotter
Constructor and Description |
---|
OpenOrdersListener(BlotterDataExtractor blotterDataExtractor,
java.lang.String user,
OrderPermission orderViewPermission) |
Modifier and Type | Method and Description |
---|---|
boolean |
isInterested(com.caplin.ret.trapi.fx.FXOrder order) |
void |
onBulkPreviousOrdersReceived(java.util.List<com.caplin.ret.trapi.fx.order.CachedOrder> cachedOrders) |
void |
onDisconnect() |
void |
onEventHistoryReceived(com.caplin.ret.trapi.fx.order.OrderEventHistories eventHistory) |
void |
onLimitOrderActivate(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderActivateFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderCancel(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderCancelFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderCancelPass(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderCompleted(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderDeactivate(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderDeactivateFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderDelete(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderDeleteFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderFillBooked(com.caplin.ret.trapi.fx.order.OrderFillEvent event) |
void |
onLimitOrderModification(com.caplin.ret.trapi.fx.order.OrderModificationEvent event) |
void |
onLimitOrderModifyFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderRegister(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderRegisterFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderReject(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderTimeout(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderToleranceFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event) |
void |
onLimitOrderTolerancePass(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onLimitOrderTraderCancelled(com.caplin.ret.trapi.fx.order.OrderEvent event) |
void |
onPreviousOrderReceived(com.caplin.ret.trapi.fx.FXOrder previousOrder) |
java.lang.String |
toDisplayString() |
@Inject public OpenOrdersListener(@Nonnull BlotterDataExtractor blotterDataExtractor, @Nonnull java.lang.String user, @Nonnull OrderPermission orderViewPermission)
public void onLimitOrderDelete(@Nonnull com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderDelete
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onEventHistoryReceived(@Nonnull com.caplin.ret.trapi.fx.order.OrderEventHistories eventHistory)
onEventHistoryReceived
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderModification(@Nonnull com.caplin.ret.trapi.fx.order.OrderModificationEvent event)
onLimitOrderModification
in interface com.caplin.ret.trapi.fx.order.listener.OrderModifyRequestListener
public void onLimitOrderFillBooked(@Nonnull com.caplin.ret.trapi.fx.order.OrderFillEvent event)
onLimitOrderFillBooked
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderReject(@Nonnull com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderReject
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onPreviousOrderReceived(@Nonnull com.caplin.ret.trapi.fx.FXOrder previousOrder)
onPreviousOrderReceived
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onBulkPreviousOrdersReceived(@Nonnull java.util.List<com.caplin.ret.trapi.fx.order.CachedOrder> cachedOrders)
onBulkPreviousOrdersReceived
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public boolean isInterested(com.caplin.ret.trapi.fx.FXOrder order)
isInterested
in interface com.caplin.ret.trapi.fx.order.listener.OrderListener
@Nonnull public java.lang.String toDisplayString()
toDisplayString
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderModifyFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderModifyFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderModifyRequestListener
public void onLimitOrderCompleted(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderCompleted
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderTraderCancelled(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderTraderCancelled
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderTimeout(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderTimeout
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onDisconnect()
onDisconnect
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderRegister(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderRegister
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderRegisterFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderRegisterFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderActivate(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderActivate
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderActivateFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderActivateFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderTolerancePass(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderTolerancePass
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderToleranceFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderToleranceFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderDeactivate(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderDeactivate
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderDeactivateFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderDeactivateFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderDeleteFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderDeleteFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderCancel(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderCancel
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderCancelPass(com.caplin.ret.trapi.fx.order.OrderEvent event)
onLimitOrderCancelPass
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
public void onLimitOrderCancelFail(com.caplin.ret.trapi.fx.order.OrderErrorEvent event)
onLimitOrderCancelFail
in interface com.caplin.ret.trapi.fx.order.listener.OrderEventListener
Copyright © 2019 Caplin Systems.