Browse Source

Polishing

pull/808/head
Juergen Hoeller 11 years ago
parent
commit
92bf32b9be
  1. 8
      spring-web/src/main/java/org/springframework/web/util/WebUtils.java
  2. 11
      spring-websocket/src/main/java/org/springframework/web/socket/server/standard/UndertowRequestUpgradeStrategy.java
  3. 9
      spring-websocket/src/main/java/org/springframework/web/socket/sockjs/transport/SockJsSession.java
  4. 8
      spring-websocket/src/main/java/org/springframework/web/socket/sockjs/transport/session/AbstractSockJsSession.java

8
spring-web/src/main/java/org/springframework/web/util/WebUtils.java

@ -191,7 +191,7 @@ public abstract class WebUtils {
* i.e. the value of the "defaultHtmlEscape" context-param in {@code web.xml} * i.e. the value of the "defaultHtmlEscape" context-param in {@code web.xml}
* (if any). Falls back to {@code false} in case of no explicit default given. * (if any). Falls back to {@code false} in case of no explicit default given.
* @param servletContext the servlet context of the web application * @param servletContext the servlet context of the web application
* @return whether default HTML escaping is enabled (default is false) * @return whether default HTML escaping is enabled (default is {@code false})
* @deprecated as of Spring 4.1, in favor of {@link #getDefaultHtmlEscape} * @deprecated as of Spring 4.1, in favor of {@link #getDefaultHtmlEscape}
*/ */
@Deprecated @Deprecated
@ -211,7 +211,8 @@ public abstract class WebUtils {
* an actual boolean value specified, allowing to have a context-specific * an actual boolean value specified, allowing to have a context-specific
* default in case of no setting at the global level. * default in case of no setting at the global level.
* @param servletContext the servlet context of the web application * @param servletContext the servlet context of the web application
* @return whether default HTML escaping is enabled (null = no explicit default) * @return whether default HTML escaping is enabled for the given application
* ({@code null} = no explicit default)
*/ */
public static Boolean getDefaultHtmlEscape(ServletContext servletContext) { public static Boolean getDefaultHtmlEscape(ServletContext servletContext) {
if (servletContext == null) { if (servletContext == null) {
@ -231,7 +232,8 @@ public abstract class WebUtils {
* an actual boolean value specified, allowing to have a context-specific * an actual boolean value specified, allowing to have a context-specific
* default in case of no setting at the global level. * default in case of no setting at the global level.
* @param servletContext the servlet context of the web application * @param servletContext the servlet context of the web application
* @return whether response encoding is used for HTML escaping (null = no explicit default) * @return whether response encoding is to be used for HTML escaping
* ({@code null} = no explicit default)
* @since 4.1.2 * @since 4.1.2
*/ */
public static Boolean getResponseEncodedHtmlEscape(ServletContext servletContext) { public static Boolean getResponseEncodedHtmlEscape(ServletContext servletContext) {

11
spring-websocket/src/main/java/org/springframework/web/socket/server/standard/UndertowRequestUpgradeStrategy.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -55,11 +55,12 @@ import org.springframework.http.server.ServerHttpResponse;
import org.springframework.util.ClassUtils; import org.springframework.util.ClassUtils;
import org.springframework.web.socket.server.HandshakeFailureException; import org.springframework.web.socket.server.HandshakeFailureException;
/** /**
* A {@link org.springframework.web.socket.server.RequestUpgradeStrategy} for use * A {@link org.springframework.web.socket.server.RequestUpgradeStrategy} for use
* with WildFly and its underlying Undertow web server. * with WildFly and its underlying Undertow web server.
* *
* <p>Compatible with Undertow 1.0, 1.1, 1.2 - as included in WildFly 8.x and 9.0.
*
* @author Rossen Stoyanchev * @author Rossen Stoyanchev
* @since 4.0.1 * @since 4.0.1
*/ */
@ -201,11 +202,11 @@ public class UndertowRequestUpgradeStrategy extends AbstractStandardUpgradeStrat
Collections.<Class<?>, List<InstanceFactory<? extends Encoder>>>emptyMap(), Collections.<Class<?>, List<InstanceFactory<? extends Encoder>>>emptyMap(),
Collections.<Class<?>, List<InstanceFactory<? extends Decoder>>>emptyMap()); Collections.<Class<?>, List<InstanceFactory<? extends Decoder>>>emptyMap());
try { try {
return undertow11Present ? return (undertow11Present ?
endpointConstructor.newInstance(endpointRegistration, endpointConstructor.newInstance(endpointRegistration,
new EndpointInstanceFactory(endpoint), null, encodingFactory, null) : new EndpointInstanceFactory(endpoint), null, encodingFactory, null) :
endpointConstructor.newInstance(endpointRegistration, endpointConstructor.newInstance(endpointRegistration,
new EndpointInstanceFactory(endpoint), null, encodingFactory); new EndpointInstanceFactory(endpoint), null, encodingFactory));
} }
catch (Exception ex) { catch (Exception ex) {
throw new HandshakeFailureException("Failed to instantiate ConfiguredServerEndpoint", ex); throw new HandshakeFailureException("Failed to instantiate ConfiguredServerEndpoint", ex);

9
spring-websocket/src/main/java/org/springframework/web/socket/sockjs/transport/SockJsSession.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -34,9 +34,10 @@ public interface SockJsSession extends WebSocketSession {
long getTimeSinceLastActive(); long getTimeSinceLastActive();
/** /**
* Disable SockJS heartbeat, presumably because a higher level protocol has * Disable the SockJS heartbeat, presumably because a higher-level protocol
* heartbeats enabled for the session. It is not recommended to disable this * has heartbeats enabled for the session already. It is not recommended to
* otherwise as it helps proxies to know the connection is not hanging. * disable this otherwise, as it helps proxies to know the connection is
* not hanging.
*/ */
void disableHeartbeat(); void disableHeartbeat();

8
spring-websocket/src/main/java/org/springframework/web/socket/sockjs/transport/session/AbstractSockJsSession.java

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -52,7 +52,7 @@ import org.springframework.web.socket.sockjs.transport.SockJsSession;
*/ */
public abstract class AbstractSockJsSession implements SockJsSession { public abstract class AbstractSockJsSession implements SockJsSession {
private static enum State {NEW, OPEN, CLOSED} private enum State {NEW, OPEN, CLOSED}
/** /**
@ -339,7 +339,7 @@ public abstract class AbstractSockJsSession implements SockJsSession {
catch (Throwable closeFailure) { catch (Throwable closeFailure) {
// Nothing of consequence, already forced disconnect // Nothing of consequence, already forced disconnect
} }
throw new SockJsTransportFailureException("Failed to write " + frame, this.getId(), ex); throw new SockJsTransportFailureException("Failed to write " + frame, getId(), ex);
} }
} }
@ -360,7 +360,7 @@ public abstract class AbstractSockJsSession implements SockJsSession {
} }
} }
else { else {
logger.debug("Terminating connection after failure to send message to client.", failure); logger.debug("Terminating connection after failure to send message to client", failure);
} }
} }

Loading…
Cancel
Save