Package ch.psi.wica.services.stream

Class WicaStreamMonitoredValueCollectorService

java.lang.Object

ch.psi.wica.services.stream.WicaStreamMonitoredValueCollectorService

@Service
@ThreadSafe
public class WicaStreamMonitoredValueCollectorService
extends Object

Constructor Summary

Constructors

Constructor	Description
WicaStreamMonitoredValueCollectorService(int bufferSize, org.springframework.context.ApplicationEventPublisher applicationEventPublisher, WicaChannelValueTimestampRewriter wicaChannelValueTimestampRewriter, 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)
void	handleWicaChannelMonitoredValueUpdateEvent(WicaChannelMonitoredValueUpdateEvent event)
void	handleWicaChannelPolledMonitorValueUpdateEvent(WicaChannelPolledMonitorValueUpdateEvent event)

Methods inherited from class java.lang.Object

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

Constructor Details

WicaStreamMonitoredValueCollectorService

public WicaStreamMonitoredValueCollectorService(@Value("${wica.channel-monitored-value-buffer-size}")
 int bufferSize,
 @Autowired
 org.springframework.context.ApplicationEventPublisher applicationEventPublisher,
 @Autowired
 WicaChannelValueTimestampRewriter wicaChannelValueTimestampRewriter,
 @Autowired
 WicaChannelValueFilteringService wicaChannelValueFilteringService)

Method Details

get

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

getLatest

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

handleWicaChannelMonitoredValueUpdateEvent

@EventListener
public void handleWicaChannelMonitoredValueUpdateEvent(WicaChannelMonitoredValueUpdateEvent event)

handleWicaChannelPolledMonitorValueUpdateEvent

@EventListener
public void handleWicaChannelPolledMonitorValueUpdateEvent(WicaChannelPolledMonitorValueUpdateEvent event)

handleUpdateEvent

@EventListener
public void handleUpdateEvent(WicaChannelPolledValueUpdateEvent event)