public class NrtBrokerLocal extends Object implements NrtBroker, NrtBrokerLocalMBean
| Constructor and Description | 
|---|
| NrtBrokerLocal() | 
| Modifier and Type | Method and Description | 
|---|---|
| Integer | getMeasurementSetSize() | 
| ProtocolCollector | getProtocolCollector(String protocol) | 
| List<ProtocolCollector> | getProtocolCollectors() | 
| void | publishCollectionJob(CollectionJob collectionJob) | 
| List<MeasurementSet> | receiveMeasurementSets(String destination) | 
| void | setProtocolCollectors(List<ProtocolCollector> protocolCollectors) | 
public void publishCollectionJob(CollectionJob collectionJob)
publishCollectionJob in interface NrtBrokerpublic List<MeasurementSet> receiveMeasurementSets(String destination)
receiveMeasurementSets in interface NrtBrokerpublic ProtocolCollector getProtocolCollector(String protocol)
public void setProtocolCollectors(List<ProtocolCollector> protocolCollectors)
public List<ProtocolCollector> getProtocolCollectors()
public Integer getMeasurementSetSize()
getMeasurementSetSize in interface NrtBrokerLocalMBeanCopyright © 2019. All rights reserved.