try {
FcpClient fcpClient = new FcpClient(clientName, node.getHostname(), node.getPort());
fcpClient.connect();
+ nodeClients.put(node, fcpClient);
+ nodeListenerSupport.fireNodeConnected(node);
} catch (UnknownHostException uhe1) {
nodeListenerSupport.fireNodeConnectionFailed(node, uhe1);
} catch (IOException ioe1) {
*/
public void disconnect(Node node) {
logger.log(Level.FINEST, "disconnect(node=" + node + ")");
+ if (!nodes.contains(node)) {
+ logger.log(Level.WARNING, "Was told to disconnect from a node (" + node + ") I don’t know about!");
+ return;
+ }
}
/**