ConsumerException
throws ConsumerException {
} else if (e instanceof ConsumerException) {
ConsumerException ce = (ConsumerException)e;
throws ConsumerException {
throws ConsumerException {
public void dataDropped(DropEvent e) throws ConsumerException {
throw new ConsumerException(drop.getDefaultMessage(),
public void dataReceived(DataEvent e) throws ConsumerException {}
dataDropped(DropEvent e) throws ConsumerException
throw new ConsumerException(drop.getDefaultMessage(), drop);
errorEncountered(ErrorEvent e) throws ConsumerException
throw new ConsumerException(error.getDefaultMessage(), error);
public void processStateChanged(ProcessEvent e) throws ConsumerException {}
public void dataReceived(DataEvent e) throws ConsumerException;
public void dataDropped(DropEvent e) throws ConsumerException;
public void errorEncountered(ErrorEvent e) throws ConsumerException;
public void processStateChanged(ProcessEvent e) throws ConsumerException;
nextProbeData(ProbeData probeData) throws ConsumerException
dataDropped(Drop drop) throws ConsumerException
errorEncountered(Error error) throws ConsumerException
processStateChanged(ProcessState processState) throws ConsumerException
fireDataReceived(DataEvent e) throws ConsumerException
fireDataDropped(DropEvent e) throws ConsumerException
fireErrorEncountered(ErrorEvent e) throws ConsumerException
fireProcessStateChanged(ProcessEvent e) throws ConsumerException