com.devexperts.qd
Interface QDCollector

All Superinterfaces:
QDStatsContainer, SubscriptionContainer
All Known Subinterfaces:
QDHistory, QDStream, QDTicker
All Known Implementing Classes:
LoggedCollector, LoggedHistory, LoggedStream, LoggedTicker

public interface QDCollector
extends SubscriptionContainer, QDStatsContainer

The QDCollector represents a hub which collects subscription from data consumers and distributes it among data providers and at the same time it collects data from data providers and distributes it among data consumers. The data consumers are represented by their QDAgent, and the data providers are represented by their QDDistributor.


Method Summary
 QDAgent createAgent(SubscriptionFilter filter)
          Creates new agent with specified subscription filter.
 QDAgent createAgent(SubscriptionFilter filter, java.lang.String key_properties)
           
 QDDistributor createDistributor(SubscriptionFilter filter)
          Creates new distributor with specified subscription filter.
 QDDistributor createDistributor(SubscriptionFilter filter, java.lang.String key_properties)
           
 QDContract getContract()
          Retruns contract that this collector provides.
 DataScheme getScheme()
          Returns data scheme used by this QD component.
 java.lang.String getSymbol(char[] chars, int offset, int length)
           
 void setErrorHandler(QDErrorHandler error_handler)
          Sets errors handler for all errors that are happening during notification of agents and distributors.
 
Methods inherited from interface com.devexperts.qd.SubscriptionContainer
examineSubscription, getSubscriptionSize, isSubscribed
 
Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer
getStats
 

Method Detail

getScheme

DataScheme getScheme()
Returns data scheme used by this QD component.


getContract

QDContract getContract()
Retruns contract that this collector provides.


createAgent

QDAgent createAgent(SubscriptionFilter filter)
Creates new agent with specified subscription filter. Specify null to use no filter.


createAgent

QDAgent createAgent(SubscriptionFilter filter,
                    java.lang.String key_properties)

createDistributor

QDDistributor createDistributor(SubscriptionFilter filter)
Creates new distributor with specified subscription filter. Specify null to use no filter.


createDistributor

QDDistributor createDistributor(SubscriptionFilter filter,
                                java.lang.String key_properties)

setErrorHandler

void setErrorHandler(QDErrorHandler error_handler)
Sets errors handler for all errors that are happening during notification of agents and distributors. Default error handler for collector is intialized via DataScheme.getService(java.lang.Class) method and QDErrorHandler.DEFAULT is used if no override is found.


getSymbol

java.lang.String getSymbol(char[] chars,
                           int offset,
                           int length)