package com.cloudera.flume.handlers.endtoend;
import java.io.IOException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public void start(String group)
throws IOException;
public void end(String group)
throws IOException;
public void err(String group)
throws IOException;
public void expired(String key)
throws IOException;
public static class Empty implements AckListener {
static final Logger LOG = LoggerFactory.getLogger(Empty.class);
@Override
public void end(String group)
throws IOException {
LOG.info("Empty Ack Listener ended " + group);
}
@Override
public void err(String group)
throws IOException {
LOG.info("Empty Ack Listener erred " + group);
}
@Override
public void expired(String group)
throws IOException {
LOG.info("Empty Ack Listener expired " + group);
}
@Override
public void start(String group)
throws IOException {
LOG.info("Empty Ack Listener began " + group);
}
}
}