Refactor subscriptions

Author: oliemansm

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

@@ -14,7 +14,7 @@ class SubscriptionConnectionInitCommand implements SubscriptionCommand {
 
   @Override
   public void apply(SubscriptionSession session, OperationMessage message) {
-    log.info("Apollo subscription connection init: {}", session);
+    log.debug("Apollo subscription connection init: {}", session);
     try {
       connectionListeners.forEach(it -> it.onConnect(session, message));
       session.sendMessage(new OperationMessage(Type.GQL_CONNECTION_ACK, message.getId(), null));

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

@@ -26,7 +26,7 @@ class SubscriptionStartCommand implements SubscriptionCommand {
 
   @Override
   public void apply(SubscriptionSession session, OperationMessage message) {
-    log.info("Apollo subscription start: {} --> {}", session, message.getPayload());
+    log.debug("Apollo subscription start: {} --> {}", session, message.getPayload());
     connectionListeners.forEach(it -> it.onStart(session, message));
     CompletableFuture<ExecutionResult> executionResult = executeAsync(message.getPayload(), session);
     executionResult.thenAccept(result -> handleSubscriptionStart(session, message.getId(), result));

graphql-java-servlet/src/main/java/graphql/servlet/subscriptions/WebSocketSendSubscriber.java

@@ -17,15 +17,13 @@ public class WebSocketSendSubscriber implements Subscriber<String> {
 
   @Override
   public void onSubscribe(Subscription subscription) {
-    log.info("Subscribe to publisher");
     subscriptionRef.set(subscription);
     subscriptionRef.get().request(1);
   }
 
   @Override
   public void onNext(String message) {
     subscriptionRef.get().request(1);
-    log.info("Send message: {}", message);
     if (session.isOpen()) {
       try {
         session.getBasicRemote().sendText(message);