32
32
import de .rwth .idsg .steve .ocpp .ws .ChargePointServiceInvoker ;
33
33
import de .rwth .idsg .steve .ocpp .ws .SessionContextStore ;
34
34
import de .rwth .idsg .steve .ocpp .ws .ocpp12 .Ocpp12TypeStore ;
35
- import de .rwth .idsg .steve .ocpp .ws .ocpp12 .Ocpp12WebSocketEndpoint ;
36
35
import de .rwth .idsg .steve .ocpp .ws .pipeline .OutgoingCallPipeline ;
37
36
import de .rwth .idsg .steve .repository .dto .ChargePointSelect ;
38
37
import ocpp .cp ._2010 ._08 .ChargePointService ;
44
43
* @since 10.03.2018
45
44
*/
46
45
@ Service
46
+ @ Qualifier ("ChargePointService12_Invoker" )
47
47
public class ChargePointService12_InvokerImpl implements ChargePointService12_Invoker {
48
48
49
49
private final ChargePointServiceInvoker wsHelper ;
50
50
private final ClientProviderWithCache <ChargePointService > soapHelper ;
51
51
52
- public ChargePointService12_InvokerImpl (OutgoingCallPipeline pipeline , @ Qualifier ("sessionContextStore12" ) SessionContextStore sessionContextStore , ClientProvider clientProvider ) {
52
+ public ChargePointService12_InvokerImpl (
53
+ OutgoingCallPipeline pipeline ,
54
+ @ Qualifier ("sessionContextStore12" ) SessionContextStore sessionContextStore ,
55
+ ClientProvider clientProvider
56
+ ) {
53
57
this .wsHelper = new ChargePointServiceInvoker (pipeline , sessionContextStore , Ocpp12TypeStore .INSTANCE );
54
58
this .soapHelper = new ClientProviderWithCache <>(clientProvider );
55
59
}
56
60
57
61
@ Override
58
62
public void reset (ChargePointSelect cp , ResetTask task ) {
59
63
if (cp .isSoap ()) {
60
- create (cp ).resetAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
64
+ create (cp ).resetAsync (
65
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
66
+ );
61
67
} else {
62
68
runPipeline (cp , task );
63
69
}
@@ -66,7 +72,9 @@ public void reset(ChargePointSelect cp, ResetTask task) {
66
72
@ Override
67
73
public void clearCache (ChargePointSelect cp , ClearCacheTask task ) {
68
74
if (cp .isSoap ()) {
69
- create (cp ).clearCacheAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
75
+ create (cp ).clearCacheAsync (
76
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
77
+ );
70
78
} else {
71
79
runPipeline (cp , task );
72
80
}
@@ -75,7 +83,9 @@ public void clearCache(ChargePointSelect cp, ClearCacheTask task) {
75
83
@ Override
76
84
public void getDiagnostics (ChargePointSelect cp , GetDiagnosticsTask task ) {
77
85
if (cp .isSoap ()) {
78
- create (cp ).getDiagnosticsAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
86
+ create (cp ).getDiagnosticsAsync (
87
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
88
+ );
79
89
} else {
80
90
runPipeline (cp , task );
81
91
}
@@ -84,7 +94,9 @@ public void getDiagnostics(ChargePointSelect cp, GetDiagnosticsTask task) {
84
94
@ Override
85
95
public void updateFirmware (ChargePointSelect cp , UpdateFirmwareTask task ) {
86
96
if (cp .isSoap ()) {
87
- create (cp ).updateFirmwareAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
97
+ create (cp ).updateFirmwareAsync (
98
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
99
+ );
88
100
} else {
89
101
runPipeline (cp , task );
90
102
}
@@ -93,7 +105,9 @@ public void updateFirmware(ChargePointSelect cp, UpdateFirmwareTask task) {
93
105
@ Override
94
106
public void unlockConnector (ChargePointSelect cp , UnlockConnectorTask task ) {
95
107
if (cp .isSoap ()) {
96
- create (cp ).unlockConnectorAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
108
+ create (cp ).unlockConnectorAsync (
109
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
110
+ );
97
111
} else {
98
112
runPipeline (cp , task );
99
113
}
@@ -102,7 +116,9 @@ public void unlockConnector(ChargePointSelect cp, UnlockConnectorTask task) {
102
116
@ Override
103
117
public void changeAvailability (ChargePointSelect cp , ChangeAvailabilityTask task ) {
104
118
if (cp .isSoap ()) {
105
- create (cp ).changeAvailabilityAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
119
+ create (cp ).changeAvailabilityAsync (
120
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
121
+ );
106
122
} else {
107
123
runPipeline (cp , task );
108
124
}
@@ -111,7 +127,9 @@ public void changeAvailability(ChargePointSelect cp, ChangeAvailabilityTask task
111
127
@ Override
112
128
public void changeConfiguration (ChargePointSelect cp , ChangeConfigurationTask task ) {
113
129
if (cp .isSoap ()) {
114
- create (cp ).changeConfigurationAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
130
+ create (cp ).changeConfigurationAsync (
131
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
132
+ );
115
133
} else {
116
134
runPipeline (cp , task );
117
135
}
@@ -120,7 +138,9 @@ public void changeConfiguration(ChargePointSelect cp, ChangeConfigurationTask ta
120
138
@ Override
121
139
public void remoteStartTransaction (ChargePointSelect cp , RemoteStartTransactionTask task ) {
122
140
if (cp .isSoap ()) {
123
- create (cp ).remoteStartTransactionAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
141
+ create (cp ).remoteStartTransactionAsync (
142
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
143
+ );
124
144
} else {
125
145
runPipeline (cp , task );
126
146
}
@@ -129,7 +149,9 @@ public void remoteStartTransaction(ChargePointSelect cp, RemoteStartTransactionT
129
149
@ Override
130
150
public void remoteStopTransaction (ChargePointSelect cp , RemoteStopTransactionTask task ) {
131
151
if (cp .isSoap ()) {
132
- create (cp ).remoteStopTransactionAsync (task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ()));
152
+ create (cp ).remoteStopTransactionAsync (
153
+ task .getOcpp12Request (), cp .getChargeBoxId (), task .getOcpp12Handler (cp .getChargeBoxId ())
154
+ );
133
155
} else {
134
156
runPipeline (cp , task );
135
157
}
0 commit comments