From 031cca7c1cea4dad0b37446d3ae2565aa7494f73 Mon Sep 17 00:00:00 2001
From: Kai Zimmermann <kai.zimmermann@bosch-si.com>
Date: Tue, 1 Mar 2016 17:12:59 +0100
Subject: [PATCH] Removed sleep.

Signed-off-by: Kai Zimmermann <kai.zimmermann@bosch-si.com>
---
 .../simulator/amqp/SpReceiverService.java     | 47 ++++++++-----------
 1 file changed, 20 insertions(+), 27 deletions(-)

diff --git a/examples/hawkbit-device-simulator/src/main/java/org/eclipse/hawkbit/simulator/amqp/SpReceiverService.java b/examples/hawkbit-device-simulator/src/main/java/org/eclipse/hawkbit/simulator/amqp/SpReceiverService.java
index 6f0ac732e..ee8ae1a0e 100644
--- a/examples/hawkbit-device-simulator/src/main/java/org/eclipse/hawkbit/simulator/amqp/SpReceiverService.java
+++ b/examples/hawkbit-device-simulator/src/main/java/org/eclipse/hawkbit/simulator/amqp/SpReceiverService.java
@@ -13,7 +13,6 @@ import java.util.Map;
 import org.eclipse.hawkbit.dmf.amqp.api.EventTopic;
 import org.eclipse.hawkbit.dmf.amqp.api.MessageHeaderKey;
 import org.eclipse.hawkbit.dmf.amqp.api.MessageType;
-import org.eclipse.hawkbit.dmf.json.model.ActionStatus;
 import org.eclipse.hawkbit.dmf.json.model.DownloadAndUpdateRequest;
 import org.eclipse.hawkbit.simulator.AbstractSimulatedDevice;
 import org.eclipse.hawkbit.simulator.DeviceSimulatorUpdater;
@@ -139,31 +138,25 @@ public class SpReceiverService extends ReceiverService {
                 DownloadAndUpdateRequest.class);
         final Long actionId = downloadAndUpdateRequest.getActionId();
 
-        try {
-            Thread.sleep(1_000);
-        } catch (final InterruptedException e) {
-            LOGGER.error("Sleep interrupted", e);
-        }
-
-        spSenderService.sendActionStatusMessage(tenant, ActionStatus.RUNNING,
-                "device Simulator retrieved update request. proceeding with simulation.", actionId);
-        deviceUpdater.startUpdate(tenant, thingId, actionId, downloadAndUpdateRequest.getSoftwareModules().get(0)
-                .getModuleVersion(), new UpdaterCallback() {
-            @Override
-            public void updateFinished(final AbstractSimulatedDevice device, final Long actionId) {
-                switch (device.getResponseStatus()) {
-                case SUCCESSFUL:
-                    spSenderService.finishUpdateProcess(new SimulatedUpdate(device.getTenant(), device.getId(),
-                            actionId), "Simulation complete!");
-                    break;
-                case ERROR:
-                    spSenderService.finishUpdateProcessWithError(new SimulatedUpdate(device.getTenant(),
-                            device.getId(), actionId), "Simulation complete with error!");
-                    break;
-                default:
-                    break;
-                }
-            }
-        });
+        deviceUpdater.startUpdate(tenant, thingId, actionId,
+                downloadAndUpdateRequest.getSoftwareModules().get(0).getModuleVersion(), new UpdaterCallback() {
+                    @Override
+                    public void updateFinished(final AbstractSimulatedDevice device, final Long actionId) {
+                        switch (device.getResponseStatus()) {
+                        case SUCCESSFUL:
+                            spSenderService.finishUpdateProcess(
+                                    new SimulatedUpdate(device.getTenant(), device.getId(), actionId),
+                                    "Simulation complete!");
+                            break;
+                        case ERROR:
+                            spSenderService.finishUpdateProcessWithError(
+                                    new SimulatedUpdate(device.getTenant(), device.getId(), actionId),
+                                    "Simulation complete with error!");
+                            break;
+                        default:
+                            break;
+                        }
+                    }
+                });
     }
 }