lingwei.kong/hawkbit
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Migrated to lambda

Browse Source
This commit is contained in:
Kai Zimmermann
2016-03-03 10:15:59 +01:00
parent 13a0e5d98f
commit b7f94891a4
1 changed files with 14 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
examples/hawkbit-device-simulator/src/main/java/org/eclipse/hawkbit/simulator/amqp/SpReceiverService.java
View File

@@ -14,9 +14,7 @@ import org.eclipse.hawkbit.dmf.amqp.api.EventTopic;
import org.eclipse.hawkbit.dmf.amqp.api.MessageHeaderKey; import org.eclipse.hawkbit.dmf.amqp.api.MessageHeaderKey;
import org.eclipse.hawkbit.dmf.amqp.api.MessageType; import org.eclipse.hawkbit.dmf.amqp.api.MessageType;
import org.eclipse.hawkbit.dmf.json.model.DownloadAndUpdateRequest; import org.eclipse.hawkbit.dmf.json.model.DownloadAndUpdateRequest;
import org.eclipse.hawkbit.simulator.AbstractSimulatedDevice;
import org.eclipse.hawkbit.simulator.DeviceSimulatorUpdater; import org.eclipse.hawkbit.simulator.DeviceSimulatorUpdater;
import org.eclipse.hawkbit.simulator.DeviceSimulatorUpdater.UpdaterCallback;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.Message;
@@ -139,23 +137,20 @@ public class SpReceiverService extends ReceiverService {
final Long actionId = downloadAndUpdateRequest.getActionId(); final Long actionId = downloadAndUpdateRequest.getActionId();
deviceUpdater.startUpdate(tenant, thingId, actionId, deviceUpdater.startUpdate(tenant, thingId, actionId,
downloadAndUpdateRequest.getSoftwareModules().get(0).getModuleVersion(), new UpdaterCallback() { downloadAndUpdateRequest.getSoftwareModules().get(0).getModuleVersion(), (device, actionId1) -> {
@Override switch (device.getResponseStatus()) {
public void updateFinished(final AbstractSimulatedDevice device, final Long actionId) { case SUCCESSFUL:
switch (device.getResponseStatus()) { spSenderService.finishUpdateProcess(
case SUCCESSFUL: new SimulatedUpdate(device.getTenant(), device.getId(), actionId1),
spSenderService.finishUpdateProcess( "Simulation complete!");
new SimulatedUpdate(device.getTenant(), device.getId(), actionId), break;
"Simulation complete!"); case ERROR:
break; spSenderService.finishUpdateProcessWithError(
case ERROR: new SimulatedUpdate(device.getTenant(), device.getId(), actionId1),
spSenderService.finishUpdateProcessWithError( "Simulation complete with error!");
new SimulatedUpdate(device.getTenant(), device.getId(), actionId), break;
"Simulation complete with error!"); default:
break; break;
default:
break;
}
} }
}); });
} }