private final String clientName;
/** The FCP connection to the node. */
- private FcpConnection fcpConnection;
+ private FcpConnection fcpConnection = null;
/** Listeners for high-level client events. */
private List<HighLevelClientListener> highLevelClientListeners = Collections.synchronizedList(new ArrayList<HighLevelClientListener>());
*/
private void fireProgressReceived(String identifier, HighLevelProgress highLevelProgress) {
for (HighLevelProgressListener highLevelProgressListener: highLevelProgressListeners) {
- highLevelProgressListener.progressReceived(identifier, highLevelProgress);
+ highLevelProgressListener.progressReceived(this, identifier, highLevelProgress);
}
}
fcpConnection.close();
}
fcpConnection = null;
- fireClientDisconnected(throwable);
}
/**
}
cancelIdentifier(null);
disconnect(throwable);
+ fireClientDisconnected(throwable);
}
/**