Bug 8055: use method references instead of lambdas 51/53151/4
authorStephen Kitt <skitt@redhat.com>
Thu, 9 Mar 2017 08:16:44 +0000 (09:16 +0100)
committerStephen Kitt <skitt@redhat.com>
Thu, 23 Mar 2017 13:07:18 +0000 (14:07 +0100)
Change-Id: I34e0108612abe51bbf9fe19e4cf5cdbe41592cef
Signed-off-by: Stephen Kitt <skitt@redhat.com>
hwvtepsouthbound/hwvtepsouthbound-impl/src/main/java/org/opendaylight/ovsdb/hwvtepsouthbound/reconciliation/ReconciliationManager.java
library/impl/src/main/java/org/opendaylight/ovsdb/lib/impl/OvsdbClientImpl.java
southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/reconciliation/ReconciliationManager.java

index 3d6374f9de97213783dcc961330f253e7efc906b..a3a4bd5a4e1d4f642b69927ca358c8f169e15deb 100644 (file)
@@ -75,7 +75,7 @@ public class ReconciliationManager implements AutoCloseable {
     public void enqueueForRetry(final ReconciliationTask task) {
         LOG.trace("Reconciliation task re-queued for re-execution {}",task);
         reconTaskManager.cacheTask(task, taskTriager.schedule(
-                () -> task.checkReadinessAndProcess(), task.retryDelayInMills(), TimeUnit.MILLISECONDS
+                task::checkReadinessAndProcess, task.retryDelayInMills(), TimeUnit.MILLISECONDS
             )
         );
     }
index c660caec5b7c952fbfc77edf9f8f7d961648aa50..0864d519c61e12bd766a428ddb550a1375ca4409 100644 (file)
@@ -185,7 +185,7 @@ public class OvsdbClientImpl implements OvsdbClient {
                                                             final MonitorCallBack callback) {
 
         final ImmutableMap<String, MonitorRequest> reqMap = Maps.uniqueIndex(monitorRequest,
-            input -> input.getTableName());
+                MonitorRequest::getTableName);
 
         final MonitorHandle monitorHandle = new MonitorHandle(UUID.randomUUID().toString());
         registerCallback(monitorHandle, callback, dbSchema);
@@ -209,7 +209,7 @@ public class OvsdbClientImpl implements OvsdbClient {
                                                            final MonitorCallBack callback) {
 
         final ImmutableMap<String, MonitorRequest> reqMap = Maps.uniqueIndex(monitorRequest,
-            input -> input.getTableName());
+                MonitorRequest::getTableName);
 
         registerCallback(monitorHandle, callback, dbSchema);
 
index 62bc5ad205568474f76faf93a71a0adcc9626e21..4b99c549169d1eb6d449d63640a893111236b95b 100644 (file)
@@ -116,7 +116,7 @@ public class ReconciliationManager implements AutoCloseable {
     public void enqueueForRetry(final ReconciliationTask task) {
         LOG.trace("Reconciliation task re-queued for re-execution {}",task);
         reconTaskManager.cacheTask(task, taskTriager.schedule(
-                () -> task.checkReadinessAndProcess(), task.retryDelayInMills(), TimeUnit.MILLISECONDS
+                task::checkReadinessAndProcess, task.retryDelayInMills(), TimeUnit.MILLISECONDS
             )
         );
     }