Code Review
/
netconf.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix checkstyle
[netconf.git]
/
netconf
/
mdsal-netconf-notification
/
src
/
main
/
java
/
org
/
opendaylight
/
netconf
/
mdsal
/
notification
/
impl
/
NetconfNotificationManager.java
diff --git
a/netconf/mdsal-netconf-notification/src/main/java/org/opendaylight/netconf/mdsal/notification/impl/NetconfNotificationManager.java
b/netconf/mdsal-netconf-notification/src/main/java/org/opendaylight/netconf/mdsal/notification/impl/NetconfNotificationManager.java
index 63ea9be8c70dab5c4b30057d09dcf57be248110f..60221039d09df7d79a14899517f6dce440f872cf 100644
(file)
--- a/
netconf/mdsal-netconf-notification/src/main/java/org/opendaylight/netconf/mdsal/notification/impl/NetconfNotificationManager.java
+++ b/
netconf/mdsal-netconf-notification/src/main/java/org/opendaylight/netconf/mdsal/notification/impl/NetconfNotificationManager.java
@@
-115,8
+115,7
@@
public class NetconfNotificationManager implements NetconfNotificationCollector,
LOG.trace("Notification listener registered for stream: {}", stream);
LOG.trace("Notification listener registered for stream: {}", stream);
- final GenericNotificationListenerReg genericNotificationListenerReg =
- new GenericNotificationListenerReg(listener) {
+ final GenericNotificationListenerReg reg = new GenericNotificationListenerReg(listener) {
@Override
public void close() {
synchronized (NetconfNotificationManager.this) {
@Override
public void close() {
synchronized (NetconfNotificationManager.this) {
@@
-126,8
+125,8
@@
public class NetconfNotificationManager implements NetconfNotificationCollector,
}
};
}
};
- notificationListeners.put(BASE_STREAM_NAME,
genericNotificationListenerR
eg);
- return
genericNotificationListenerR
eg;
+ notificationListeners.put(BASE_STREAM_NAME,
r
eg);
+ return
r
eg;
}
@Override
}
@Override
@@
-193,8
+192,7
@@
public class NetconfNotificationManager implements NetconfNotificationCollector,
availableStreams.add(streamName);
availableStreams.add(streamName);
- final GenericNotificationPublisherReg genericNotificationPublisherReg =
- new GenericNotificationPublisherReg(this, streamName) {
+ final GenericNotificationPublisherReg reg = new GenericNotificationPublisherReg(this, streamName) {
@Override
public void close() {
synchronized (NetconfNotificationManager.this) {
@Override
public void close() {
synchronized (NetconfNotificationManager.this) {
@@
-203,10
+201,10
@@
public class NetconfNotificationManager implements NetconfNotificationCollector,
}
};
}
};
- notificationPublishers.add(
genericNotificationPublisherR
eg);
+ notificationPublishers.add(
r
eg);
notifyStreamAdded(stream);
notifyStreamAdded(stream);
- return
genericNotificationPublisherR
eg;
+ return
r
eg;
}
@SuppressFBWarnings(value = "UPM_UNCALLED_PRIVATE_METHOD",
}
@SuppressFBWarnings(value = "UPM_UNCALLED_PRIVATE_METHOD",
@@
-339,7
+337,7
@@
public class NetconfNotificationManager implements NetconfNotificationCollector,
}
@Override
}
@Override
- public void onYangLibraryUpdate(YangLibraryUpdate yangLibraryUpdate) {
+ public void onYangLibraryUpdate(
final
YangLibraryUpdate yangLibraryUpdate) {
baseRegistration.onNotification(BASE_STREAM_NAME,
transformUtil.transform(yangLibraryUpdate, YANG_LIBRARY_UPDATE_PATH));
}
baseRegistration.onNotification(BASE_STREAM_NAME,
transformUtil.transform(yangLibraryUpdate, YANG_LIBRARY_UPDATE_PATH));
}