ch.algotrader.python.services

Class PythonGenericEventsService

java.lang.Object

ch.algotrader.python.services.PythonGenericEventsService

Direct Known Subclasses:

PythonGenericEventsServiceStub

public class PythonGenericEventsService
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
PythonGenericEventsService(GenericEventsService genericEventsService, GenericCacheFacade genericCacheFacade)

Method Summary

Modifier and Type	Method and Description
java.util.List<GenericEventVO>	downloadHistoricalGenericEvents(java.lang.String selector, java.time.ZonedDateTime startDate, java.time.ZonedDateTime endDate, MarketDataEventType marketDataEventType)
GenericEventVO	getLastGenericEvent(java.lang.String selector, java.lang.Class<? extends GenericEventVO> clazz)
<T extends GenericEventVO> java.util.List<T>	getLastNGenericEvents(int n, java.lang.String selector, java.lang.Class<T> clazz)
void	initSubscriptions(java.lang.String sessionQualifier)
boolean	recognizeSession(java.lang.String sessionQualifier)
void	storeHistoricalGenericEvents(java.lang.String selector, java.time.ZonedDateTime startDate, java.time.ZonedDateTime endDate, MarketDataEventType marketDataEventType, java.lang.Class<? extends GenericEventVO> clazz, boolean replace)
void	subscribe(java.lang.String selector, MarketDataEventType marketDataEventType, java.lang.String strategyName, AdapterType adapterType, java.util.Map<java.lang.String,java.io.Serializable> propertyMap)
void	unsubscribe(java.lang.String selector, MarketDataEventType marketDataEventType, java.lang.String strategyName, AdapterType adapterType, java.util.Map<java.lang.String,java.io.Serializable> properties)

Methods inherited from class java.lang.Object

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

Constructor Detail

PythonGenericEventsService

public PythonGenericEventsService(GenericEventsService genericEventsService,
                                  GenericCacheFacade genericCacheFacade)

Method Detail

getLastGenericEvent

public GenericEventVO getLastGenericEvent(java.lang.String selector,
                                          java.lang.Class<? extends GenericEventVO> clazz)

getLastNGenericEvents

public <T extends GenericEventVO> java.util.List<T> getLastNGenericEvents(int n,
                                                                          java.lang.String selector,
                                                                          java.lang.Class<T> clazz)

storeHistoricalGenericEvents

public void storeHistoricalGenericEvents(java.lang.String selector,
                                         java.time.ZonedDateTime startDate,
                                         java.time.ZonedDateTime endDate,
                                         MarketDataEventType marketDataEventType,
                                         java.lang.Class<? extends GenericEventVO> clazz,
                                         boolean replace)

downloadHistoricalGenericEvents

public java.util.List<GenericEventVO> downloadHistoricalGenericEvents(java.lang.String selector,
                                                                      java.time.ZonedDateTime startDate,
                                                                      java.time.ZonedDateTime endDate,
                                                                      MarketDataEventType marketDataEventType)

subscribe

public void subscribe(java.lang.String selector,
                      MarketDataEventType marketDataEventType,
                      java.lang.String strategyName,
                      AdapterType adapterType,
                      java.util.Map<java.lang.String,java.io.Serializable> propertyMap)

unsubscribe

public void unsubscribe(java.lang.String selector,
                        MarketDataEventType marketDataEventType,
                        java.lang.String strategyName,
                        AdapterType adapterType,
                        java.util.Map<java.lang.String,java.io.Serializable> properties)

initSubscriptions

public void initSubscriptions(java.lang.String sessionQualifier)

recognizeSession

public boolean recognizeSession(java.lang.String sessionQualifier)