diff --git a/graphql-kickstart-spring-webflux/src/main/java/graphql/kickstart/spring/webflux/apollo/ReactiveApolloSubscriptionSession.java b/graphql-kickstart-spring-webflux/src/main/java/graphql/kickstart/spring/webflux/apollo/ReactiveApolloSubscriptionSession.java
index b03497c8..1ae78b1e 100644
--- a/graphql-kickstart-spring-webflux/src/main/java/graphql/kickstart/spring/webflux/apollo/ReactiveApolloSubscriptionSession.java
+++ b/graphql-kickstart-spring-webflux/src/main/java/graphql/kickstart/spring/webflux/apollo/ReactiveApolloSubscriptionSession.java
@@ -21,6 +21,12 @@ public boolean isOpen() {
     return session.isOpen();
   }
 
+  @Override
+  public void close(String reason) {
+    super.close(reason);
+    session.close(reason);
+  }
+
   @Override
   public Map<String, Object> getUserProperties() {
     return session.getUserProperties();