Class LiveTransferEvents

java.lang.Object

ecmwf.ecpds.master.LiveTransferEvents

public final class LiveTransferEvents
extends Object

Bounded, expiring latest events with conditional acknowledgement for concurrent producers.

Constructor Summary

Constructors

Constructor	Description
LiveTransferEvents(long activeLifetime, long terminalLifetime, int capacity)

Method Summary

Modifier and Type	Method	Description
void	acknowledge(List<LiveTransferSample> delivered)
void	clear()
boolean	offer(LiveTransferSample sample)
List<LiveTransferSample>	snapshot()

Methods inherited from class Object

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

Constructor Details

LiveTransferEvents

public LiveTransferEvents(long activeLifetime,
 long terminalLifetime,
 int capacity)

Method Details

offer

public boolean offer(LiveTransferSample sample)

snapshot

public List<LiveTransferSample> snapshot()

acknowledge

public void acknowledge(List<LiveTransferSample> delivered)

clear

public void clear()