@InitializationPriority(value=BROKER_INTERFACE, priority=0) public class QHMarketDataServiceImpl extends NativeMarketDataServiceImpl implements ExternalMarketDataService, InitializingServiceI
Constructor and Description |
---|
QHMarketDataServiceImpl(QHAdapter qHAdapter,
QHMarketDataMessageHandler qHMarketDataMessageHandler,
SessionStateHolder sessionStateHolder,
Engine serverEngine,
TickerIdCache tickerIdCache,
AggregatedOrderBook aggregatedOrderBook) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
java.lang.String |
getAdapterType()
Returns the adapter type for this for this service
|
java.lang.String |
getSessionQualifier()
Returns the session qualifier for this service
|
void |
init()
Abstract initialization method that needs to be overwritten by the Service implementing this
Interface
|
boolean |
initSubscriptionReady()
Returns
true if the external service is ready to accept initial
subscriptions. |
void |
subscribe(java.util.Collection<Security> securities)
Subscribes the given securities with the external market data provider.
|
void |
subscribe(Security security)
Subscribes the given security with the external market data provider.
|
void |
unsubscribe(Security security)
Un-subscribes the given security with the external market data provider.
|
esperSubscribe, esperUnsubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
reconnect, unsubscribe
public QHMarketDataServiceImpl(QHAdapter qHAdapter, QHMarketDataMessageHandler qHMarketDataMessageHandler, SessionStateHolder sessionStateHolder, Engine serverEngine, TickerIdCache tickerIdCache, AggregatedOrderBook aggregatedOrderBook)
public boolean initSubscriptionReady()
ExternalMarketDataService
true
if the external service is ready to accept initial
subscriptions. Returns false
if the external service is not ready
or initial subscriptions have already been activated.initSubscriptionReady
in interface ExternalMarketDataService
public void init()
InitializingServiceI
init
in interface InitializingServiceI
public void destroy() throws java.lang.Exception
java.lang.Exception
public void subscribe(Security security)
ExternalMarketDataService
subscribe
in interface ExternalMarketDataService
public void subscribe(java.util.Collection<Security> securities)
ExternalMarketDataService
subscribe
in interface ExternalMarketDataService
public void unsubscribe(Security security)
ExternalMarketDataService
unsubscribe
in interface ExternalMarketDataService
public java.lang.String getAdapterType()
ExternalMarketDataService
getAdapterType
in interface ExternalMarketDataService
public java.lang.String getSessionQualifier()
ExternalMarketDataService
getSessionQualifier
in interface ExternalMarketDataService