OvsdbRPC ovsdb = factory.getClient(node, OvsdbRPC.class);
connection.setRpc(ovsdb);
ovsdb.registerCallback(instance);
+ ovsdbConnections.put(identifier, connection);
// Keeping the Initial inventory update(s) on its own thread.
new Thread() {
public void run() {
try {
initializeInventoryForNewNode(connection);
- ovsdbConnections.put(identifier, connection);
- } catch (InterruptedException e) {
- e.printStackTrace();
- } catch (ExecutionException e) {
+ } catch (Exception e) {
e.printStackTrace();
+ ovsdbConnections.remove(identifier);
}
}
public Thread initializeConnectionParams(String identifier, Connection connection) {