diff --git a/spring-integration-websocket/src/main/java/org/springframework/integration/websocket/ClientWebSocketContainer.java b/spring-integration-websocket/src/main/java/org/springframework/integration/websocket/ClientWebSocketContainer.java index d8022b49c2..463259df63 100644 --- a/spring-integration-websocket/src/main/java/org/springframework/integration/websocket/ClientWebSocketContainer.java +++ b/spring-integration-websocket/src/main/java/org/springframework/integration/websocket/ClientWebSocketContainer.java @@ -267,7 +267,7 @@ public final class ClientWebSocketContainer extends IntegrationWebSocketContaine } @Override - protected boolean isConnected() { + public boolean isConnected() { return ((ClientWebSocketContainer.this.clientSession != null) && (ClientWebSocketContainer.this.clientSession.isOpen())); }