Added support to show errors when connection initialization fails for any reason. Also fixed bug on JSON processing exception that was not being properly reported

Author: guilhermeblanco

gradle.properties

@@ -1,4 +1,4 @@
-version = 9.2.1-SNAPSHOT
+version = 9.2.1.001-SNAPSHOT
 group = com.graphql-java-kickstart
 
 PROJECT_NAME = graphql-java-servlet

graphql-java-kickstart/src/main/java/graphql/kickstart/execution/subscriptions/apollo/ApolloSubscriptionConsumer.java

@@ -23,7 +23,7 @@ public void accept(String request) {
       SubscriptionCommand command = commandProvider.getByType(message.getType());
       command.apply(session, message);
     } catch (JsonProcessingException e) {
-      log.error("Cannot read subscription command '{}'", request, e);
+      log.error("Cannot read subscription command '{}': {}", request, e);
       session.sendMessage(new OperationMessage(Type.GQL_CONNECTION_ERROR, null, e.getMessage()));
     }
   }

graphql-java-kickstart/src/main/java/graphql/kickstart/execution/subscriptions/apollo/SubscriptionConnectionInitCommand.java

@@ -19,6 +19,7 @@ public void apply(SubscriptionSession session, OperationMessage message) {
       connectionListeners.forEach(it -> it.onConnect(session, message));
       session.sendMessage(new OperationMessage(Type.GQL_CONNECTION_ACK, message.getId(), null));
     } catch (Throwable t) {
+      log.error("Cannot initialize subscription command '{}': {}", message, t);
       session.sendMessage(new OperationMessage(Type.GQL_CONNECTION_ERROR, message.getId(), t.getMessage()));
     }
   }