private static final Set<Capability> CAPABILITIES = Collections.emptySet();
- public MdsalMonitoringMapperFactory(final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener,
- final NetconfMonitoringService netconfMonitoringService,
- final MonitoringToMdsalWriter monitoringToMdsalWriter) {
+ public MdsalMonitoringMapperFactory(
+ final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener,
+ final NetconfMonitoringService netconfMonitoringService,
+ final MonitoringToMdsalWriter monitoringToMdsalWriter) {
this.netconfOperationServiceFactoryListener = netconfOperationServiceFactoryListener;
this.monitoringToMdsalWriter = monitoringToMdsalWriter;
@Override
public Set<Capability> getCapabilities() {
- // TODO
- // No capabilities exposed to prevent clashes with schemas from mdsal-netconf-connector (it exposes all the schemas)
- // If the schemas exposed by mdsal-netconf-connector are filtered, this class would expose monitoring related models
+ // TODO No capabilities exposed to prevent clashes with schemas from mdsal-netconf-connector (it exposes
+ // all the schemas). If the schemas exposed by mdsal-netconf-connector are filtered, this class would expose
+ // monitoring related models.
return CAPABILITIES;
}
}
/**
- * Invoke using blueprint
+ * Invoked using blueprint.
*/
@Override
public void close() {
}
/**
- * Invoke using blueprint
+ * Invoked using blueprint.
*/
@Override
public void close() {
- runTransaction((tx) -> tx.delete(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(NetconfState.class)));
+ runTransaction((tx) -> tx.delete(LogicalDatastoreType.OPERATIONAL,
+ InstanceIdentifier.create(NetconfState.class)));
}
@Override
@Override
public void onCapabilitiesChanged(Capabilities capabilities) {
- runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, CAPABILITIES_INSTANCE_IDENTIFIER, capabilities));
+ runTransaction((tx) -> tx.put(LogicalDatastoreType.OPERATIONAL, CAPABILITIES_INSTANCE_IDENTIFIER,
+ capabilities));
}
@Override
}
/**
- * Invoke using blueprint
+ * Invoked using blueprint.
*/
public void start() {
serverMonitoringDependency.registerCapabilitiesListener(this);
}
@Override
- public void onFailure(Throwable t) {
- LOG.warn("Unable to update netconf state", t);
+ public void onFailure(Throwable throwable) {
+ LOG.warn("Unable to update netconf state", throwable);
}
});
}
public class MonitoringToMdsalWriterTest {
- private static final InstanceIdentifier<NetconfState> INSTANCE_IDENTIFIER = InstanceIdentifier.create(NetconfState.class);
+ private static final InstanceIdentifier<NetconfState> INSTANCE_IDENTIFIER =
+ InstanceIdentifier.create(NetconfState.class);
@Mock
private NetconfMonitoringService monitoring;
@Test
public void testOnCapabilityChanged() throws Exception {
- final InstanceIdentifier<Capabilities> capabilitiesId = InstanceIdentifier.create(NetconfState.class).child(Capabilities.class);
+ final InstanceIdentifier<Capabilities> capabilitiesId =
+ InstanceIdentifier.create(NetconfState.class).child(Capabilities.class);
writer.start();
final Capabilities capabilities = new CapabilitiesBuilder().build();
writer.onCapabilitiesChanged(capabilities);
@Test
public void testOnSchemasChanged() throws Exception {
- final InstanceIdentifier<Schemas> schemasId = InstanceIdentifier.create(NetconfState.class).child(Schemas.class);
+ final InstanceIdentifier<Schemas> schemasId =
+ InstanceIdentifier.create(NetconfState.class).child(Schemas.class);
writer.start();
final Schemas schemas = new SchemasBuilder().build();
writer.onSchemasChanged(schemas);
Session session = new SessionBuilder()
.setSessionId(1L)
.build();
- final InstanceIdentifier<Session> id = InstanceIdentifier.create(NetconfState.class).child(Sessions.class).child(Session.class, session.getKey());
+ final InstanceIdentifier<Session> id =
+ InstanceIdentifier.create(NetconfState.class)
+ .child(Sessions.class)
+ .child(Session.class, session.getKey());
writer.start();
writer.onSessionStarted(session);
InOrder inOrder = inOrder(writeTransaction);
Session session = new SessionBuilder()
.setSessionId(1L)
.build();
- final InstanceIdentifier<Session> id = InstanceIdentifier.create(NetconfState.class).child(Sessions.class).child(Session.class, session.getKey());
+ final InstanceIdentifier<Session> id =
+ InstanceIdentifier.create(NetconfState.class)
+ .child(Sessions.class)
+ .child(Session.class, session.getKey());
writer.start();
writer.onSessionEnded(session);
InOrder inOrder = inOrder(writeTransaction);
List<Session> sessions = new ArrayList<>();
sessions.add(session1);
sessions.add(session2);
- final InstanceIdentifier<Session> id1 = InstanceIdentifier.create(NetconfState.class).child(Sessions.class).child(Session.class, session1.getKey());
- final InstanceIdentifier<Session> id2 = InstanceIdentifier.create(NetconfState.class).child(Sessions.class).child(Session.class, session2.getKey());
+ final InstanceIdentifier<Session> id1 =
+ InstanceIdentifier.create(NetconfState.class)
+ .child(Sessions.class)
+ .child(Session.class, session1.getKey());
+ final InstanceIdentifier<Session> id2 =
+ InstanceIdentifier.create(NetconfState.class)
+ .child(Sessions.class)
+ .child(Session.class, session2.getKey());
writer.start();
writer.onSessionsUpdated(sessions);
InOrder inOrder = inOrder(writeTransaction);