1 package at.ac.tuwien.sbc.valesriegler.xvsm;
3 import java.io.Serializable;
6 import org.mozartspaces.capi3.AnyCoordinator;
7 import org.mozartspaces.capi3.FifoCoordinator;
8 import org.mozartspaces.core.Capi;
9 import org.mozartspaces.core.ContainerReference;
10 import org.mozartspaces.core.MzsConstants;
11 import org.mozartspaces.core.MzsConstants.RequestTimeout;
15 * @author Gregor Riegler <gregor DOT riegler AT gmail DOT com>
19 public abstract class SpaceListenerImpl extends SpaceListener {
21 private final Capi capi;
22 private final ContainerReference cref;
24 public SpaceListenerImpl(Capi core, ContainerReference cref) {
29 public SpaceListenerImpl(Capi core, ContainerReference cref, boolean lookAround) {
31 this.lookAround = lookAround;
34 public SpaceListenerImpl(Capi core, ContainerReference cref, long milliseconds) {
36 this.timeout = milliseconds;
40 List<? extends Serializable> getEntries() throws Exception {
41 return capi.read(cref, FifoCoordinator
42 .newSelector(MzsConstants.Selecting.COUNT_MAX),
43 RequestTimeout.DEFAULT, null);