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 NrtBroker
public List<MeasurementSet> receiveMeasurementSets(String destination)
receiveMeasurementSets
in interface NrtBroker
public ProtocolCollector getProtocolCollector(String protocol)
public void setProtocolCollectors(List<ProtocolCollector> protocolCollectors)
public List<ProtocolCollector> getProtocolCollectors()
public Integer getMeasurementSetSize()
getMeasurementSetSize
in interface NrtBrokerLocalMBean
Copyright © 2021. All rights reserved.