Replace "if(" with "if ("
This commit is contained in:
@@ -216,7 +216,7 @@ public class MethodMessageHandlerTests {
|
||||
@Override
|
||||
protected String getMappingForMethod(Method method, Class<?> handlerType) {
|
||||
String methodName = method.getName();
|
||||
if(methodName.startsWith("handler")) {
|
||||
if (methodName.startsWith("handler")) {
|
||||
return "/" + methodName;
|
||||
}
|
||||
return null;
|
||||
@@ -240,7 +240,7 @@ public class MethodMessageHandlerTests {
|
||||
protected String getMatchingMapping(String mapping, Message<?> message) {
|
||||
|
||||
String destination = getLookupDestination(getDestination(message));
|
||||
if(mapping.equals(destination) || this.pathMatcher.match(mapping, destination)) {
|
||||
if (mapping.equals(destination) || this.pathMatcher.match(mapping, destination)) {
|
||||
return mapping;
|
||||
}
|
||||
return null;
|
||||
|
||||
@@ -97,8 +97,8 @@ public abstract class HtmlEscapingAwareTag extends RequestContextAwareTag {
|
||||
*/
|
||||
protected String htmlEscape(String content) {
|
||||
String out = content;
|
||||
if(isHtmlEscape()) {
|
||||
if(isResponseEncodedHtmlEscape()) {
|
||||
if (isHtmlEscape()) {
|
||||
if (isResponseEncodedHtmlEscape()) {
|
||||
out = HtmlUtils.htmlEscape(content, this.pageContext.getResponse().getCharacterEncoding());
|
||||
}
|
||||
else {
|
||||
|
||||
@@ -188,12 +188,12 @@ public class MvcNamespaceTests {
|
||||
List<HttpMessageConverter<?>> converters = adapter.getMessageConverters();
|
||||
assertTrue(converters.size() > 0);
|
||||
for(HttpMessageConverter<?> converter : converters) {
|
||||
if(converter instanceof AbstractJackson2HttpMessageConverter) {
|
||||
if (converter instanceof AbstractJackson2HttpMessageConverter) {
|
||||
ObjectMapper objectMapper = ((AbstractJackson2HttpMessageConverter)converter).getObjectMapper();
|
||||
assertFalse(objectMapper.getDeserializationConfig().isEnabled(MapperFeature.DEFAULT_VIEW_INCLUSION));
|
||||
assertFalse(objectMapper.getSerializationConfig().isEnabled(MapperFeature.DEFAULT_VIEW_INCLUSION));
|
||||
assertFalse(objectMapper.getDeserializationConfig().isEnabled(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES));
|
||||
if(converter instanceof MappingJackson2XmlHttpMessageConverter) {
|
||||
if (converter instanceof MappingJackson2XmlHttpMessageConverter) {
|
||||
assertEquals(XmlMapper.class, objectMapper.getClass());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -160,12 +160,12 @@ public class WebMvcConfigurationSupportTests {
|
||||
List<HttpMessageConverter<?>> converters = adapter.getMessageConverters();
|
||||
assertEquals(9, converters.size());
|
||||
for(HttpMessageConverter<?> converter : converters) {
|
||||
if(converter instanceof AbstractJackson2HttpMessageConverter) {
|
||||
if (converter instanceof AbstractJackson2HttpMessageConverter) {
|
||||
ObjectMapper objectMapper = ((AbstractJackson2HttpMessageConverter)converter).getObjectMapper();
|
||||
assertFalse(objectMapper.getDeserializationConfig().isEnabled(MapperFeature.DEFAULT_VIEW_INCLUSION));
|
||||
assertFalse(objectMapper.getSerializationConfig().isEnabled(MapperFeature.DEFAULT_VIEW_INCLUSION));
|
||||
assertFalse(objectMapper.getDeserializationConfig().isEnabled(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES));
|
||||
if(converter instanceof MappingJackson2XmlHttpMessageConverter) {
|
||||
if (converter instanceof MappingJackson2XmlHttpMessageConverter) {
|
||||
assertEquals(XmlMapper.class, objectMapper.getClass());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -83,7 +83,7 @@ class HandlersBeanDefinitionParser implements BeanDefinitionParser {
|
||||
ManagedList<? super Object> interceptors = WebSocketNamespaceUtils.parseBeanSubElements(interceptorsElement, context);
|
||||
String allowedOriginsAttribute = element.getAttribute("allowed-origins");
|
||||
List<String> allowedOrigins = Arrays.asList(StringUtils.tokenizeToStringArray(allowedOriginsAttribute, ","));
|
||||
if(!allowedOrigins.isEmpty()) {
|
||||
if (!allowedOrigins.isEmpty()) {
|
||||
OriginHandshakeInterceptor interceptor = new OriginHandshakeInterceptor();
|
||||
interceptor.setAllowedOrigins(allowedOrigins);
|
||||
interceptors.add(interceptor);
|
||||
|
||||
@@ -286,7 +286,7 @@ class MessageBrokerBeanDefinitionParser implements BeanDefinitionParser {
|
||||
ManagedList<? super Object> interceptors = WebSocketNamespaceUtils.parseBeanSubElements(interceptorsElement, context);
|
||||
String allowedOriginsAttribute = element.getAttribute("allowed-origins");
|
||||
List<String> allowedOrigins = Arrays.asList(StringUtils.tokenizeToStringArray(allowedOriginsAttribute, ","));
|
||||
if(!allowedOrigins.isEmpty()) {
|
||||
if (!allowedOrigins.isEmpty()) {
|
||||
OriginHandshakeInterceptor interceptor = new OriginHandshakeInterceptor();
|
||||
interceptor.setAllowedOrigins(allowedOrigins);
|
||||
interceptors.add(interceptor);
|
||||
|
||||
@@ -105,7 +105,7 @@ class WebSocketNamespaceUtils {
|
||||
ManagedList<? super Object> interceptors = WebSocketNamespaceUtils.parseBeanSubElements(interceptorsElement, context);
|
||||
String allowedOriginsAttribute = element.getAttribute("allowed-origins");
|
||||
List<String> allowedOrigins = Arrays.asList(StringUtils.tokenizeToStringArray(allowedOriginsAttribute, ","));
|
||||
if(!allowedOrigins.isEmpty()) {
|
||||
if (!allowedOrigins.isEmpty()) {
|
||||
sockJsServiceDef.getPropertyValues().add("allowedOrigins", allowedOrigins);
|
||||
OriginHandshakeInterceptor interceptor = new OriginHandshakeInterceptor();
|
||||
interceptor.setAllowedOrigins(allowedOrigins);
|
||||
|
||||
@@ -116,7 +116,7 @@ public abstract class AbstractWebSocketHandlerRegistration<M> implements WebSock
|
||||
protected HandshakeInterceptor[] getInterceptors() {
|
||||
List<HandshakeInterceptor> interceptors = new ArrayList<HandshakeInterceptor>();
|
||||
interceptors.addAll(this.interceptors);
|
||||
if(!this.allowedOrigins.isEmpty()) {
|
||||
if (!this.allowedOrigins.isEmpty()) {
|
||||
OriginHandshakeInterceptor interceptor = new OriginHandshakeInterceptor();
|
||||
interceptor.setAllowedOrigins(this.allowedOrigins);
|
||||
interceptors.add(interceptor);
|
||||
|
||||
@@ -113,7 +113,7 @@ public class WebMvcStompWebSocketEndpointRegistration implements StompWebSocketE
|
||||
protected HandshakeInterceptor[] getInterceptors() {
|
||||
List<HandshakeInterceptor> interceptors = new ArrayList<HandshakeInterceptor>();
|
||||
interceptors.addAll(this.interceptors);
|
||||
if(!this.allowedOrigins.isEmpty()) {
|
||||
if (!this.allowedOrigins.isEmpty()) {
|
||||
OriginHandshakeInterceptor interceptor = new OriginHandshakeInterceptor();
|
||||
interceptor.setAllowedOrigins(this.allowedOrigins);
|
||||
interceptors.add(interceptor);
|
||||
|
||||
@@ -65,7 +65,7 @@ public class OriginHandshakeInterceptor implements HandshakeInterceptor {
|
||||
@Override
|
||||
public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response,
|
||||
WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
|
||||
if(!isValidOrigin(request)) {
|
||||
if (!isValidOrigin(request)) {
|
||||
response.setStatusCode(HttpStatus.FORBIDDEN);
|
||||
if (logger.isDebugEnabled()) {
|
||||
logger.debug("Handshake request rejected, Origin header value "
|
||||
|
||||
@@ -165,7 +165,7 @@ public class UndertowXhrTransport extends AbstractXhrTransport implements XhrTra
|
||||
try {
|
||||
final ClientRequest request = new ClientRequest().setMethod(method).setPath(url.getPath());
|
||||
request.getRequestHeaders().add(HttpString.tryFromString(HttpHeaders.HOST), url.getHost());
|
||||
if(body !=null && !body.isEmpty()) {
|
||||
if (body !=null && !body.isEmpty()) {
|
||||
request.getRequestHeaders().add(HttpString.tryFromString(HttpHeaders.CONTENT_LENGTH), body.length());
|
||||
}
|
||||
addHttpHeaders(request, headers);
|
||||
@@ -224,11 +224,11 @@ public class UndertowXhrTransport extends AbstractXhrTransport implements XhrTra
|
||||
}
|
||||
});
|
||||
try {
|
||||
if(body != null) {
|
||||
if (body != null) {
|
||||
result.getRequestChannel().write(ByteBuffer.wrap(body.getBytes()));
|
||||
}
|
||||
result.getRequestChannel().shutdownWrites();
|
||||
if(!result.getRequestChannel().flush()) {
|
||||
if (!result.getRequestChannel().flush()) {
|
||||
result.getRequestChannel().getWriteSetter()
|
||||
.set(ChannelListeners.<StreamSinkChannel>flushingChannelListener(null, null));
|
||||
result.getRequestChannel().resumeWrites();
|
||||
@@ -295,7 +295,7 @@ public class UndertowXhrTransport extends AbstractXhrTransport implements XhrTra
|
||||
public void completed(final ClientExchange result) {
|
||||
|
||||
ClientResponse response = result.getResponse();
|
||||
if(response.getResponseCode() != 200) {
|
||||
if (response.getResponseCode() != 200) {
|
||||
HttpStatus status = HttpStatus.valueOf(response.getResponseCode());
|
||||
IoUtils.safeClose(result.getConnection());
|
||||
onFailure(new HttpServerErrorException(status, "Unexpected XHR receive status"));
|
||||
@@ -310,7 +310,7 @@ public class UndertowXhrTransport extends AbstractXhrTransport implements XhrTra
|
||||
}
|
||||
try {
|
||||
result.getRequestChannel().shutdownWrites();
|
||||
if(!result.getRequestChannel().flush()) {
|
||||
if (!result.getRequestChannel().flush()) {
|
||||
result.getRequestChannel().getWriteSetter()
|
||||
.set(ChannelListeners.<StreamSinkChannel>flushingChannelListener(null, null));
|
||||
result.getRequestChannel().resumeWrites();
|
||||
|
||||
@@ -424,7 +424,7 @@ public abstract class AbstractSockJsService implements SockJsService {
|
||||
HttpHeaders responseHeaders = response.getHeaders();
|
||||
String origin = requestHeaders.getOrigin();
|
||||
|
||||
if(!this.allowedOrigins.contains("*") && (origin == null || !this.allowedOrigins.contains(origin))) {
|
||||
if (!this.allowedOrigins.contains("*") && (origin == null || !this.allowedOrigins.contains(origin))) {
|
||||
logger.debug("Request rejected, Origin header value " + origin + " not allowed");
|
||||
response.setStatusCode(HttpStatus.FORBIDDEN);
|
||||
return false;
|
||||
@@ -439,7 +439,7 @@ public abstract class AbstractSockJsService implements SockJsService {
|
||||
// See SPR-11919 and https://issues.jboss.org/browse/WFLY-3474
|
||||
}
|
||||
|
||||
if(!this.suppressCors && origin != null && !hasCorsResponseHeaders) {
|
||||
if (!this.suppressCors && origin != null && !hasCorsResponseHeaders) {
|
||||
addCorsHeaders(request, response, httpMethods);
|
||||
}
|
||||
return true;
|
||||
@@ -498,14 +498,14 @@ public abstract class AbstractSockJsService implements SockJsService {
|
||||
public void handle(ServerHttpRequest request, ServerHttpResponse response) throws IOException {
|
||||
if (HttpMethod.GET.equals(request.getMethod())) {
|
||||
addNoCacheHeaders(response);
|
||||
if(checkAndAddCorsHeaders(request, response)) {
|
||||
if (checkAndAddCorsHeaders(request, response)) {
|
||||
response.getHeaders().setContentType(new MediaType("application", "json", UTF8_CHARSET));
|
||||
String content = String.format(INFO_CONTENT, random.nextInt(), isSessionCookieNeeded(), isWebSocketEnabled());
|
||||
response.getBody().write(content.getBytes());
|
||||
}
|
||||
}
|
||||
else if (HttpMethod.OPTIONS.equals(request.getMethod())) {
|
||||
if(checkAndAddCorsHeaders(request, response, HttpMethod.OPTIONS,
|
||||
if (checkAndAddCorsHeaders(request, response, HttpMethod.OPTIONS,
|
||||
HttpMethod.GET)) {
|
||||
addCacheHeaders(response);
|
||||
response.setStatusCode(HttpStatus.NO_CONTENT);
|
||||
|
||||
@@ -207,7 +207,7 @@ public class TransportHandlingSockJsService extends AbstractSockJsService implem
|
||||
HttpMethod supportedMethod = transportType.getHttpMethod();
|
||||
if (!supportedMethod.equals(request.getMethod())) {
|
||||
if (HttpMethod.OPTIONS.equals(request.getMethod()) && transportType.supportsCors()) {
|
||||
if(checkAndAddCorsHeaders(request, response, HttpMethod.OPTIONS, supportedMethod)) {
|
||||
if (checkAndAddCorsHeaders(request, response, HttpMethod.OPTIONS, supportedMethod)) {
|
||||
response.setStatusCode(HttpStatus.NO_CONTENT);
|
||||
addCacheHeaders(response);
|
||||
}
|
||||
@@ -251,7 +251,7 @@ public class TransportHandlingSockJsService extends AbstractSockJsService implem
|
||||
}
|
||||
|
||||
if (transportType.supportsCors()) {
|
||||
if(!checkAndAddCorsHeaders(request, response)) {
|
||||
if (!checkAndAddCorsHeaders(request, response)) {
|
||||
return;
|
||||
}
|
||||
}
|
||||
@@ -275,7 +275,7 @@ public class TransportHandlingSockJsService extends AbstractSockJsService implem
|
||||
|
||||
@Override
|
||||
protected boolean validateRequest(String serverId, String sessionId, String transport) {
|
||||
if(!this.getAllowedOrigins().contains("*") && !TransportType.fromValue(transport).supportsOrigin()) {
|
||||
if (!this.getAllowedOrigins().contains("*") && !TransportType.fromValue(transport).supportsOrigin()) {
|
||||
logger.error("Origin check has been enabled, but this transport does not support it");
|
||||
return false;
|
||||
}
|
||||
|
||||
@@ -36,7 +36,7 @@ public class ContextLoaderTestUtils {
|
||||
}
|
||||
|
||||
public static void setCurrentWebApplicationContext(ClassLoader classLoader, WebApplicationContext applicationContext) {
|
||||
if(applicationContext != null) {
|
||||
if (applicationContext != null) {
|
||||
currentContextPerThread.put(classLoader, applicationContext);
|
||||
} else {
|
||||
currentContextPerThread.remove(classLoader);
|
||||
|
||||
@@ -234,7 +234,7 @@ public class ConvertingEncoderDecoderSupportTests {
|
||||
|
||||
@Override
|
||||
public boolean equals(Object obj) {
|
||||
if(obj instanceof MyType) {
|
||||
if (obj instanceof MyType) {
|
||||
return ((MyType)obj).value.equals(value);
|
||||
}
|
||||
return false;
|
||||
|
||||
Reference in New Issue
Block a user