-\r
- private void fetchConnectionDefinitionList(){\r
- InstanceIdentifier<ConnectionDefinitions> connectiondefinitionId = InstanceIdentifier.builder(ConnectionDefinitions.class).build();\r
- ListenableFuture<Optional<ConnectionDefinitions>> connectiondefinitionFuture = dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, connectiondefinitionId);\r
- Futures.addCallback(connectiondefinitionFuture, new FutureCallback<Optional<ConnectionDefinitions>>() {\r
- @Override\r
- public void onSuccess(Optional<ConnectionDefinitions> result) {\r
- setConnectionDefinitionListFuture(result.get().getConnectionDefinition());\r
-\r
- }\r
-\r
- @Override\r
- public void onFailure(Throwable t) {\r
- LOG.error("Can not read connection definition information.", t);\r
- }\r
- });\r
- return;\r
- }\r
-\r
- private void setConnectionDefinitionListFuture(List<ConnectionDefinition> connectionDefinitionList){\r
- this.connectionDefinitionListFuture.set(connectionDefinitionList);\r
- }\r
-\r
- private List<ConnectionDefinition> getConnectionDefinitionList(){\r
- try{\r
- return connectionDefinitionListFuture.get(1, TimeUnit.SECONDS);\r
- }catch (InterruptedException | ExecutionException | TimeoutException e) {\r
- LOG.error("Cannot read role information.", e);\r
- return null;\r
- }\r
- }\r
-\r
- private Map<ConnectionType, ConnectionDefinition> getConnectionDefinition(){\r
- List<ConnectionDefinition> connectionDefinitionList = getConnectionDefinitionList();\r
- Map<ConnectionType, ConnectionDefinition> connectionDefinitionMap = new HashMap<ConnectionType, ConnectionDefinition>();\r
- if (connectionDefinitionList!=null){\r
- for (ConnectionDefinition connectionDefinition : connectionDefinitionList){\r
- connectionDefinitionMap.put(connectionDefinition.getConnectionType(),connectionDefinition);\r
- }\r
- }\r
- return connectionDefinitionMap;\r
- }\r