ch.algotrader.python.services

Class PythonMarketDataService

java.lang.Object

ch.algotrader.python.services.PythonMarketDataService

Direct Known Subclasses:

PythonMarketDataServiceStub

public class PythonMarketDataService
extends java.lang.Object

Delegates to MarketDataService from PythonStrategyService. Methods mirror delegated methods with small changes (no Optional, only VOs are used, not entities). Some are left out.

Field Summary

Fields

Modifier and Type	Field and Description
protected ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor and Description
PythonMarketDataService(MarketDataService marketDataService, GenericDao genericDao, ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method and Description
java.lang.String	findAdapterTypeBySecurity(SecurityVO securityVO)
SecurityVO	findDefaultSecurity(java.util.List<? extends SecurityVO> inputSecuritiesVOs)
SecurityVO	findDefaultSecurity(java.lang.String baseCurrency, java.lang.String transactionCurrency, boolean reverse)
java.util.List<SubscriptionVO>	getSubscriptionsByStrategy(java.lang.String strategyName) Gets all Subscriptions by the defined strategyName.
java.util.Set<java.lang.String>	getSupportedAdapterTypes() Returns all currently active data adapters.
boolean	hasVol(long securityId) Returns true if the corresponding Security is supposed to report volumes,e.g.: Stocks: true Forex: false
void	initSubscriptions() Initializes persistent subscriptions.
void	initSubscriptions(java.lang.String adapterType) Initializes persistent subscriptions for the specified adapter type.
boolean	isSupportedAdapterType(java.lang.String adapterType) Returns true if the data adapter is supported.
boolean	isTickValid(java.lang.String tickJson) Verifies if the tick is valid for the security associated with it.
java.lang.String	normalizeTick(java.lang.String tickJson) Normalize the tick value according to broker params multiplier if normaliseMarketData is enabled
void	reconnect(java.lang.String adapterType) Reconnect the adapter corresponding to the defined adapterType
protected java.lang.String	serialize(java.lang.Object object)
void	subscribe(java.lang.String strategyName, long securityId) Subscribes a Security for the defined Strategy.
void	subscribe(java.lang.String strategyName, long securityId, java.lang.String adapterType) Subscribes a Security for the defined Strategy and adapter type.
void	subscribeToCurrency(StrategyVO strategy, java.lang.String transactionCurrency) Subscribes the Forex Security needed to convert transactionCurrency and basePortfolioCurrency.
void	unsubscribe(java.lang.String strategyName, long securityId) Unsubscribes a Security for the defined Strategy.
void	unsubscribe(java.lang.String strategyName, long securityId, java.lang.String adapterType) Unsubscribes a Security for the defined Strategy and adapter type

Methods inherited from class java.lang.Object

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

Field Detail

objectMapper

protected final ObjectMapper objectMapper

Constructor Detail

PythonMarketDataService

public PythonMarketDataService(MarketDataService marketDataService,
                               GenericDao genericDao,
                               ObjectMapper objectMapper)

Method Detail

serialize

protected java.lang.String serialize(java.lang.Object object)

initSubscriptions

public void initSubscriptions()

Initializes persistent subscriptions.

initSubscriptions

public void initSubscriptions(java.lang.String adapterType)

Initializes persistent subscriptions for the specified adapter type.

subscribe

public void subscribe(java.lang.String strategyName,
                      long securityId)
               throws UnknownAdapterException

Subscribes a Security for the defined Strategy. Will be executed only if there is only one active market adapter, otherwise will throw UnknownAdapterException. If there are multiple market adapters, use subscribe(String, long, String)

Throws:

UnknownAdapterException - if there are multiple active adapters

subscribe

public void subscribe(java.lang.String strategyName,
                      long securityId,
                      java.lang.String adapterType)

Subscribes a Security for the defined Strategy and adapter type.

subscribeToCurrency

public void subscribeToCurrency(StrategyVO strategy,
                                java.lang.String transactionCurrency)

Subscribes the Forex Security needed to convert transactionCurrency and basePortfolioCurrency.

unsubscribe

public void unsubscribe(java.lang.String strategyName,
                        long securityId)
                 throws UnknownAdapterException

Unsubscribes a Security for the defined Strategy. Will be executed only if there is only one active market adapter, otherwise will throw UnknownAdapterException. If there are multiple market adapters, use unsubscribe(String, long, String)

Throws:

UnknownAdapterException - if there are multiple active adapters

unsubscribe

public void unsubscribe(java.lang.String strategyName,
                        long securityId,
                        java.lang.String adapterType)

Unsubscribes a Security for the defined Strategy and adapter type

reconnect

public void reconnect(java.lang.String adapterType)

Reconnect the adapter corresponding to the defined adapterType

getSubscriptionsByStrategy

public java.util.List<SubscriptionVO> getSubscriptionsByStrategy(java.lang.String strategyName)

Gets all Subscriptions by the defined strategyName. If corresponding Securities are Combinations, all Components will be initialized as well. In additional all Properties are initialized

getSupportedAdapterTypes

public java.util.Set<java.lang.String> getSupportedAdapterTypes()

Returns all currently active data adapters.

isSupportedAdapterType

public boolean isSupportedAdapterType(java.lang.String adapterType)

Returns true if the data adapter is supported.

isTickValid

public boolean isTickValid(java.lang.String tickJson)
                    throws java.io.IOException

Verifies if the tick is valid for the security associated with it.

Throws:

java.io.IOException

hasVol

public boolean hasVol(long securityId)

Returns true if the corresponding Security is supposed to report volumes,e.g.:

• Stocks: true
• Forex: false

normalizeTick

public java.lang.String normalizeTick(java.lang.String tickJson)
                               throws java.io.IOException

Normalize the tick value according to broker params multiplier if normaliseMarketData is enabled

Throws:

java.io.IOException

findDefaultSecurity

public SecurityVO findDefaultSecurity(java.lang.String baseCurrency,
                                      java.lang.String transactionCurrency,
                                      boolean reverse)

findDefaultSecurity

public SecurityVO findDefaultSecurity(java.util.List<? extends SecurityVO> inputSecuritiesVOs)

findAdapterTypeBySecurity

public java.lang.String findAdapterTypeBySecurity(SecurityVO securityVO)

Parameters:

securityVO - SecurityVO to find adapterType for

Returns: