Package ch.psi.wica.services.stream

Class WicaStreamPolledValueCollectorService

java.lang.Object

ch.psi.wica.services.stream.WicaStreamPolledValueCollectorService

@Service
@ThreadSafe
public class WicaStreamPolledValueCollectorService
extends Object

Constructor Summary

Constructors

Constructor	Description
WicaStreamPolledValueCollectorService(int bufferSize, WicaChannelValueFilteringService wicaChannelValueFilteringService)

Method Summary

Modifier and Type	Method	Description
Map<WicaChannel,List<WicaChannelValue>>	get(WicaStream wicaStream, LocalDateTime since)
(package private) Map<WicaChannel,List<WicaChannelValue>>	getLatest(WicaStream wicaStream)
void	handleUpdateEvent(WicaChannelPolledValueUpdateEvent event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WicaStreamPolledValueCollectorService

public WicaStreamPolledValueCollectorService(@Value("${wica.channel-polled-value-buffer-size}")
 int bufferSize,
 @Autowired
 WicaChannelValueFilteringService wicaChannelValueFilteringService)

Method Details

get

public Map<WicaChannel,List<WicaChannelValue>> get(WicaStream wicaStream,
 LocalDateTime since)

getLatest

Map<WicaChannel,List<WicaChannelValue>> getLatest(WicaStream wicaStream)

handleUpdateEvent

@EventListener
public void handleUpdateEvent(WicaChannelPolledValueUpdateEvent event)