Remove unused parameter from handleConnectionRestored

Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>
eclipse-ditto · Jul 3, 2019 · 3f78210 · 3f78210
1 parent 1f5ec2b
commit 3f78210
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java b/...src/main/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActor.java
@@ -188,7 +188,8 @@ private State<BaseClientState, BaseClientData> handleConnectionFailureWhenConnec
     @Override
     protected FSMStateFunctionBuilder<BaseClientState, BaseClientData> inAnyState() {
         return super.inAnyState()
-                .event(ConnectionRestoredStatusReport.class, this::handleConnectionRestored)
+                .event(ConnectionRestoredStatusReport.class,
+                        (report, currentData) -> this.handleConnectionRestored(currentData))
                 .event(ConnectionFailureStatusReport.class, this::handleConnectionFailure)
                 .event(ConsumerClosedStatusReport.class, this::handleConsumerClosed)
                 .event(ProducerClosedStatusReport.class, this::handleProducerClosed)
@@ -435,9 +436,7 @@ private CompletableFuture<Void> ensureJmsConnectionClosed() {
         }
     }
 
-    private FSM.State<BaseClientState, BaseClientData> handleConnectionRestored(
-            final ConnectionRestoredStatusReport statusReport,
-            final BaseClientData currentData) {
+    private FSM.State<BaseClientState, BaseClientData> handleConnectionRestored(final BaseClientData currentData) {
         if (jmsSession == null || ((JmsSession) jmsSession).isClosed()) {
             log.info("Restored connection has closed session, trying to recover...");
             recoverSession(jmsSession);