Skip to content

Commit a7198a5

Browse files
committed
Decrease apollo subscription session closed keep alive warnings to debug
1 parent d05325d commit a7198a5

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

src/main/java/graphql/servlet/GraphQLWebsocketServlet.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -184,7 +184,7 @@ public int getSessionCount() {
184184

185185
public int getSubscriptionCount() {
186186
return sessionSubscriptionCache.values().stream()
187-
.mapToInt(subscriptions -> subscriptions.getSubscriptionCount())
187+
.mapToInt(WsSessionSubscriptions::getSubscriptionCount)
188188
.sum();
189189
}
190190
}

src/main/java/graphql/servlet/internal/ApolloSubscriptionKeepAliveRunner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,11 +44,11 @@ private ScheduledFuture<?> startKeepAlive(Session session) {
4444
if (session.isOpen()) {
4545
sender.send(session, keepAliveMessage);
4646
} else {
47-
LOG.warn("Session appears to be closed. Aborting keep alive");
47+
LOG.debug("Session {} appears to be closed. Aborting keep alive", session.getId());
4848
abort(session);
4949
}
5050
} catch (Throwable t) {
51-
LOG.error("Cannot send keep alive message. Aborting keep alive", t);
51+
LOG.error("Cannot send keep alive message to session {}. Aborting keep alive", session.getId(), t);
5252
abort(session);
5353
}
5454
}, 0, keepAliveIntervalSeconds, TimeUnit.SECONDS);

src/main/java/graphql/servlet/internal/WsSessionSubscriptions.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
* @author Andrew Potter
1111
*/
1212
public class WsSessionSubscriptions {
13+
1314
private final Object lock = new Object();
1415

1516
private boolean closed = false;

0 commit comments

Comments
 (0)