package com.cloudera.flume.master;
import java.io.IOException;
import java.util.HashSet;
import java.util.Set;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
static final Logger LOG = LoggerFactory.getLogger(MasterAckManager.class);
Set<String> acked = new HashSet<String>();
acked.add(ackid);
}
synchronized public boolean check(String ackid) {
boolean committed = acked.contains(ackid);
if (committed) {
acked.remove(ackid);
}
return committed;
}
return new HashSet<String>(acked);
}
LOG.info("dumping ack manager state");
for (String s : acked) {
LOG.info(" " + s);
}
}
public void start()
throws IOException {
}
}
}