[camel] 06/10: (chores) camel-dataset: replace inner class with lambda

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 90f8aa18b04311c2d7f54d162730caa74552a9e8
Author: Gilvan Filho <gilvan.sfi...@gmail.com>
AuthorDate: Mon Dec 5 20:30:33 2022 -0300

    (chores) camel-dataset: replace inner class with lambda
---
 .../camel/component/dataset/DataSetConsumer.java      | 19 ++++++++-----------
 1 file changed, 8 insertions(+), 11 deletions(-)

diff --git 
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
 
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
index a7e2c80f93c..d147af32e63 100644
--- 
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
+++ 
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
@@ -58,19 +58,16 @@ public class DataSetConsumer extends DefaultConsumer {
         sendMessages(0, preloadSize);
         executorService = 
camelContext.getExecutorServiceManager().newSingleThreadExecutor(this, 
endpoint.getEndpointUri());
 
-        executorService.execute(new Runnable() {
-            public void run() {
-                if (endpoint.getInitialDelay() > 0) {
-                    try {
-                        Thread.sleep(endpoint.getInitialDelay());
-                    } catch (InterruptedException e) {
-                        Thread.currentThread().interrupt();
-                        return;
-                    }
+        executorService.execute(() -> {
+            if (endpoint.getInitialDelay() > 0) {
+                try {
+                    Thread.sleep(endpoint.getInitialDelay());
+                } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                    return;
                 }
-
-                sendMessages(preloadSize, dataSet.getSize());
             }
+            sendMessages(preloadSize, dataSet.getSize());
         });
     }