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 © 2020. All rights reserved.