diff --git a/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java b/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java index 7f632c385..dbbb60a66 100644 --- a/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java +++ b/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java @@ -199,14 +199,18 @@ public final int updateFirmware(UpdateFirmwareParams params, @SafeVarargs public final int remoteStartTransaction(RemoteStartTransactionParams params, OcppCallback... callbacks) { - return remoteStartTransaction(params, "Steve", callbacks); - } - + RemoteStartTransactionTask task = new RemoteStartTransactionTask(params); + return addRemoteStartTask(task, callbacks); + } @SafeVarargs public final int remoteStartTransaction(RemoteStartTransactionParams params, String caller, OcppCallback... callbacks) { RemoteStartTransactionTask task = new RemoteStartTransactionTask(params, caller); + return addRemoteStartTask(task, callbacks); + } + private int addRemoteStartTask(RemoteStartTransactionTask task, + OcppCallback... callbacks) { for (var callback : callbacks) { task.addCallback(callback); } @@ -221,14 +225,19 @@ public final int remoteStartTransaction(RemoteStartTransactionParams params, Str @SafeVarargs public final int remoteStopTransaction(RemoteStopTransactionParams params, OcppCallback... callbacks) { - return remoteStopTransaction(params, "Steve", callbacks); + RemoteStopTransactionTask task = new RemoteStopTransactionTask(params); + return addRemoteStopTask(task,callbacks); } @SafeVarargs public final int remoteStopTransaction(RemoteStopTransactionParams params, String caller, OcppCallback... callbacks) { RemoteStopTransactionTask task = new RemoteStopTransactionTask(params, caller); + return addRemoteStopTask(task,callbacks); + } + private int addRemoteStopTask(RemoteStopTransactionTask task, + OcppCallback... callbacks) { for (var callback : callbacks) { task.addCallback(callback); } @@ -243,13 +252,19 @@ public final int remoteStopTransaction(RemoteStopTransactionParams params, Strin @SafeVarargs public final int unlockConnector(UnlockConnectorParams params, OcppCallback... callbacks) { - return unlockConnector(params, "Steve", callbacks); + UnlockConnectorTask task = new UnlockConnectorTask(params); + return addUnlockConnectorTask(task, callbacks); } + @SafeVarargs public final int unlockConnector(UnlockConnectorParams params, String caller, OcppCallback... callbacks) { UnlockConnectorTask task = new UnlockConnectorTask(params, caller); + return addUnlockConnectorTask(task, callbacks); + } + private int addUnlockConnectorTask(UnlockConnectorTask task, + OcppCallback... callbacks) { for (var callback : callbacks) { task.addCallback(callback); }