Merge branch '1.1.x'

spring-boot-actuator/src/main/java/org/springframework/boot/actuate/endpoint/mvc/HealthMvcEndpoint.java

@@ -31,7 +31,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
 
 /**
  * Adapter to expose {@link HealthEndpoint} as an {@link MvcEndpoint}.
- * 
+ *
  * @author Christian Dupuis
  * @since 1.1.0
  */

spring-boot-actuator/src/main/java/org/springframework/boot/actuate/health/MongoHealthIndicator.java

@@ -24,7 +24,7 @@ import com.mongodb.CommandResult;
 /**
  * Simple implementation of a {@link HealthIndicator} returning status information for
  * Mongo data stores.
- * 
+ *
  * @author Christian Dupuis
  * @since 1.1.0
  */

spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/MessageSourceAutoConfiguration.java

@@ -53,6 +53,8 @@ import static org.springframework.util.StringUtils.trimAllWhitespace;
 @ConfigurationProperties(prefix = "spring.messages")
 public class MessageSourceAutoConfiguration {
 
+	private static final Resource[] NO_RESOURCES = {};
+
 	private String basename = "messages";
 
 	private String encoding = "utf-8";
@@ -103,27 +105,27 @@ public class MessageSourceAutoConfiguration {
 			String basename = context.getEnvironment().getProperty(
 					"spring.messages.basename", "messages");
 			for (String name : commaDelimitedListToStringArray(trimAllWhitespace(basename))) {
-				Resource[] resources;
-				try {
-					resources = new PathMatchingResourcePatternResolver(
-							context.getClassLoader()).getResources("classpath*:" + name
-							+ "*.properties");
-				}
-				catch (IOException e) {
-					continue;
-				}
-				for (Resource resource : resources) {
-
+				for (Resource resource : getResources(context.getClassLoader(), name)) {
 					if (resource.exists()) {
-						return ConditionOutcome
-								.match("Bundle found for spring.messages.basename: "
-										+ name);
+						return ConditionOutcome.match("Bundle found for "
+								+ "spring.messages.basename: " + name);
 					}
 				}
 			}
-			return ConditionOutcome
-					.noMatch("No bundle found for spring.messages.basename: " + basename);
+			return ConditionOutcome.noMatch("No bundle found for "
+					+ "spring.messages.basename: " + basename);
 		}
+
+		private Resource[] getResources(ClassLoader classLoader, String name) {
+			try {
+				return new PathMatchingResourcePatternResolver(classLoader)
+						.getResources("classpath*:" + name + "*.properties");
+			}
+			catch (IOException ex) {
+				return NO_RESOURCES;
+			}
+		}
+
 	}
 
 }

spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java

@@ -107,7 +107,8 @@ public class RabbitProperties {
 			}
 			result.add(address);
 		}
-		return result.isEmpty() ? null : StringUtils.collectionToCommaDelimitedString(result);
+		return (result.isEmpty() ? null : StringUtils
+				.collectionToCommaDelimitedString(result));
 	}
 
 	public void setPort(int port) {

spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/web/HttpMessageConverters.java

@@ -67,25 +67,34 @@ public class HttpMessageConverters implements Iterable<HttpMessageConverter<?>>
 	/**
 	 * Create a new {@link HttpMessageConverters} instance with the specified additional
 	 * converters.
-	 * @param additionalConverters additional converters to be added. New converters will
-	 * be added to the front of the list, overrides will replace existing items without
-	 * changing the order. The {@link #getConverters()} methods can be used for further
-	 * converter manipulation.
+	 * @param additionalConverters additional converters to be added. Items are added just
+	 * before any default converter of the same type (or at the front of the list if no
+	 * default converter is found) The {@link #getConverters()} methods can be used for
+	 * further converter manipulation.
 	 */
 	public HttpMessageConverters(Collection<HttpMessageConverter<?>> additionalConverters) {
 		List<HttpMessageConverter<?>> converters = new ArrayList<HttpMessageConverter<?>>();
-		List<HttpMessageConverter<?>> defaultConverters = getDefaultConverters();
-		converters.addAll(additionalConverters);
-		converters.addAll(defaultConverters);
+		List<HttpMessageConverter<?>> processing = new ArrayList<HttpMessageConverter<?>>(
+				additionalConverters);
+		for (HttpMessageConverter<?> defaultConverter : getDefaultConverters()) {
+			Iterator<HttpMessageConverter<?>> iterator = processing.iterator();
+			while (iterator.hasNext()) {
+				HttpMessageConverter<?> candidate = iterator.next();
+				if (ClassUtils.isAssignableValue(defaultConverter.getClass(), candidate)) {
+					converters.add(candidate);
+					iterator.remove();
+				}
+			}
+			converters.add(defaultConverter);
+		}
+		converters.addAll(0, processing);
 		this.converters = Collections.unmodifiableList(converters);
 	}
 
 	private List<HttpMessageConverter<?>> getDefaultConverters() {
 		List<HttpMessageConverter<?>> converters = new ArrayList<HttpMessageConverter<?>>();
-		if (ClassUtils
-				.isPresent(
-						"org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport",
-						null)) {
+		if (ClassUtils.isPresent("org.springframework.web.servlet.config.annotation."
+				+ "WebMvcConfigurationSupport", null)) {
 			converters.addAll(new WebMvcConfigurationSupport() {
 				public List<HttpMessageConverter<?>> defaultMessageConverters() {
 					return super.getMessageConverters();

spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/web/HttpMessageConvertersAutoConfiguration.java

@@ -16,7 +16,6 @@
 
 package org.springframework.boot.autoconfigure.web;
 
-import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 
@@ -53,9 +52,7 @@ public class HttpMessageConvertersAutoConfiguration {
 	@Bean
 	@ConditionalOnMissingBean
 	public HttpMessageConverters messageConverters() {
-		List<HttpMessageConverter<?>> converters = new ArrayList<HttpMessageConverter<?>>(
-				this.converters);
-		return new HttpMessageConverters(converters);
+		return new HttpMessageConverters(this.converters);
 	}
 
 	@Configuration

spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/web/HttpMessageConvertersTests.java

@@ -34,6 +34,7 @@ import org.springframework.http.converter.xml.SourceHttpMessageConverter;
 
 import static org.hamcrest.Matchers.equalTo;
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertThat;
 import static org.junit.Assert.assertTrue;
 import static org.mockito.Mockito.mock;
@@ -65,27 +66,35 @@ public class HttpMessageConvertersTests {
 	}
 
 	@Test
-	public void overrideExistingConverter() {
-		MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();
-		HttpMessageConverters converters = new HttpMessageConverters(converter);
-		assertTrue(converters.getConverters().contains(converter));
-		int count = 0;
-		for (HttpMessageConverter<?> httpMessageConverter : converters) {
-			if (httpMessageConverter instanceof MappingJackson2HttpMessageConverter) {
-				count++;
+	public void addBeforeExistingConverter() {
+		MappingJackson2HttpMessageConverter converter1 = new MappingJackson2HttpMessageConverter();
+		MappingJackson2HttpMessageConverter converter2 = new MappingJackson2HttpMessageConverter();
+		HttpMessageConverters converters = new HttpMessageConverters(converter1,
+				converter2);
+		assertTrue(converters.getConverters().contains(converter1));
+		assertTrue(converters.getConverters().contains(converter2));
+		List<MappingJackson2HttpMessageConverter> httpConverters = new ArrayList<MappingJackson2HttpMessageConverter>();
+		for (HttpMessageConverter<?> candidate : converters) {
+			if (candidate instanceof MappingJackson2HttpMessageConverter) {
+				httpConverters.add((MappingJackson2HttpMessageConverter) candidate);
 			}
 		}
 		// The existing converter is still there, but with a lower priority
-		assertEquals(2, count);
-		assertEquals(0, converters.getConverters().indexOf(converter));
+		assertEquals(3, httpConverters.size());
+		assertEquals(0, httpConverters.indexOf(converter1));
+		assertEquals(1, httpConverters.indexOf(converter2));
+		assertNotEquals(0, converters.getConverters().indexOf(converter1));
 	}
 
 	@Test
-	public void addNewConverter() {
-		HttpMessageConverter<?> converter = mock(HttpMessageConverter.class);
-		HttpMessageConverters converters = new HttpMessageConverters(converter);
-		assertTrue(converters.getConverters().contains(converter));
-		assertEquals(converter, converters.getConverters().get(0));
+	public void addNewConverters() {
+		HttpMessageConverter<?> converter1 = mock(HttpMessageConverter.class);
+		HttpMessageConverter<?> converter2 = mock(HttpMessageConverter.class);
+		HttpMessageConverters converters = new HttpMessageConverters(converter1,
+				converter2);
+		assertTrue(converters.getConverters().contains(converter1));
+		assertEquals(converter1, converters.getConverters().get(0));
+		assertEquals(converter2, converters.getConverters().get(1));
 	}
 
 }

spring-boot-cli/samples/http.groovy

@@ -20,4 +20,5 @@ class Example implements CommandLineRunner {
 		def world = new RESTClient("http://localhost:" + port).get(path:"/").data.text
 		print "Hello " + world
 	}
+
 }

spring-boot-docs/src/main/asciidoc/spring-boot-features.adoc

@@ -2004,7 +2004,6 @@ the actual port that was allocated for the duration of the tests.
 
 [[boot-features-testing-spring-boot-applications-with-spock]]
 ==== Using Spock to test Spring Boot applications
-
 If you wish to use Spock to test a Spring Boot application you should add a dependency
 on Spock's `spock-spring` module to your application's build. `spock-spring` integrates
 Spring's test framework into Spock.

spring-boot/src/main/java/org/springframework/boot/bind/PropertySourcesPropertyValues.java

@@ -72,65 +72,67 @@ public class PropertySourcesPropertyValues implements PropertyValues {
 		this.propertySources = propertySources;
 		PropertySourcesPropertyResolver resolver = new PropertySourcesPropertyResolver(
 				propertySources);
-		String[] includes = patterns == null ? new String[0] : patterns
-				.toArray(new String[0]);
-		String[] exacts = names == null ? new String[0] : names.toArray(new String[0]);
+		String[] includes = toArray(patterns);
+		String[] exacts = toArray(names);
 		for (PropertySource<?> source : propertySources) {
 			processPropertySource(source, resolver, includes, exacts);
 		}
 	}
 
+	private String[] toArray(Collection<String> strings) {
+		if (strings == null) {
+			return new String[0];
+		}
+		return strings.toArray(new String[strings.size()]);
+	}
+
 	private void processPropertySource(PropertySource<?> source,
 			PropertySourcesPropertyResolver resolver, String[] includes, String[] exacts) {
 		if (source instanceof EnumerablePropertySource) {
-			EnumerablePropertySource<?> enumerable = (EnumerablePropertySource<?>) source;
-			if (enumerable.getPropertyNames().length > 0) {
-				for (String propertyName : enumerable.getPropertyNames()) {
-					if (this.NON_ENUMERABLE_ENUMERABLES.contains(source.getName())
-							&& !PatternMatchUtils.simpleMatch(includes, propertyName)) {
-						continue;
-					}
-					Object value = source.getProperty(propertyName);
-					try {
-						value = resolver.getProperty(propertyName);
-					}
-					catch (RuntimeException ex) {
-						// Probably could not resolve placeholders, ignore it here
-					}
-					if (!this.propertyValues.containsKey(propertyName)) {
-						this.propertyValues.put(propertyName, new PropertyValue(
-								propertyName, value));
-					}
-				}
-			}
+			processEnumerablePropertySource((EnumerablePropertySource<?>) source,
+					resolver, includes, exacts);
 		}
 		else if (source instanceof CompositePropertySource) {
-			CompositePropertySource composite = (CompositePropertySource) source;
-			for (PropertySource<?> nested : extractSources(composite)) {
-				processPropertySource(nested, resolver, includes, exacts);
-			}
+			processCompositePropertySource((CompositePropertySource) source, resolver,
+					includes, exacts);
 		}
 		else {
 			// We can only do exact matches for non-enumerable property names, but
 			// that's better than nothing...
-			for (String propertyName : exacts) {
-				Object value;
-				value = resolver.getProperty(propertyName);
-				if (value != null && !this.propertyValues.containsKey(propertyName)) {
-					this.propertyValues.put(propertyName, new PropertyValue(propertyName,
-							value));
+			processDefaultPropertySource(source, resolver, includes, exacts);
+		}
+	}
+
+	private void processEnumerablePropertySource(EnumerablePropertySource<?> source,
+			PropertySourcesPropertyResolver resolver, String[] includes, String[] exacts) {
+		if (source.getPropertyNames().length > 0) {
+			for (String propertyName : source.getPropertyNames()) {
+				if (this.NON_ENUMERABLE_ENUMERABLES.contains(source.getName())
+						&& !PatternMatchUtils.simpleMatch(includes, propertyName)) {
 					continue;
 				}
-				value = source.getProperty(propertyName.toUpperCase());
-				if (value != null && !this.propertyValues.containsKey(propertyName)) {
+				Object value = source.getProperty(propertyName);
+				try {
+					value = resolver.getProperty(propertyName);
+				}
+				catch (RuntimeException ex) {
+					// Probably could not resolve placeholders, ignore it here
+				}
+				if (!this.propertyValues.containsKey(propertyName)) {
 					this.propertyValues.put(propertyName, new PropertyValue(propertyName,
 							value));
-					continue;
 				}
 			}
 		}
 	}
 
+	private void processCompositePropertySource(CompositePropertySource source,
+			PropertySourcesPropertyResolver resolver, String[] includes, String[] exacts) {
+		for (PropertySource<?> nested : extractSources(source)) {
+			processPropertySource(nested, resolver, includes, exacts);
+		}
+	}
+
 	private Collection<PropertySource<?>> extractSources(CompositePropertySource composite) {
 		Field field = ReflectionUtils.findField(CompositePropertySource.class,
 				"propertySources");
@@ -141,9 +143,24 @@ public class PropertySourcesPropertyValues implements PropertyValues {
 					.get(composite);
 			return collection;
 		}
-		catch (Exception e) {
+		catch (Exception ex) {
 			throw new IllegalStateException(
-					"Cannot extract property sources from composite", e);
+					"Cannot extract property sources from composite", ex);
+		}
+	}
+
+	private void processDefaultPropertySource(PropertySource<?> source,
+			PropertySourcesPropertyResolver resolver, String[] includes, String[] exacts) {
+		for (String propertyName : exacts) {
+			Object value = resolver.getProperty(propertyName);
+			if (value == null) {
+				value = source.getProperty(propertyName.toUpperCase());
+			}
+			if (value != null && !this.propertyValues.containsKey(propertyName)) {
+				this.propertyValues.put(propertyName, new PropertyValue(propertyName,
+						value));
+				continue;
+			}
 		}
 	}
 

spring-boot/src/main/java/org/springframework/boot/context/embedded/jetty/JettyEmbeddedServletContainer.java

@@ -76,17 +76,21 @@ public class JettyEmbeddedServletContainer implements EmbeddedServletContainer {
 			this.server.start();
 		}
 		catch (Exception ex) {
-			try {
-				// Ensure process isn't left running
-				this.server.stop();
-			}
-			catch (Exception e) {
-			}
+			// Ensure process isn't left running
+			stopSilently();
 			throw new EmbeddedServletContainerException(
 					"Unable to start embedded Jetty servlet container", ex);
 		}
 	}
 
+	private void stopSilently() {
+		try {
+			this.server.stop();
+		}
+		catch (Exception ex) {
+		}
+	}
+
 	@Override
 	public void start() throws EmbeddedServletContainerException {
 		this.server.setConnectors(this.connectors);

spring-boot/src/main/java/org/springframework/boot/context/embedded/tomcat/TomcatEmbeddedServletContainer.java

@@ -95,7 +95,6 @@ public class TomcatEmbeddedServletContainer implements EmbeddedServletContainer
 				this.tomcat.stop();
 				throw new IllegalStateException("Tomcat connector in failed state");
 			}
-
 		}
 		catch (Exception ex) {
 			throw new EmbeddedServletContainerException(
@@ -154,15 +153,19 @@ public class TomcatEmbeddedServletContainer implements EmbeddedServletContainer
 		}
 		// Ensure process isn't left running if it actually failed to start
 		if (LifecycleState.FAILED.equals(this.tomcat.getConnector().getState())) {
-			try {
-				this.tomcat.stop();
-			}
-			catch (LifecycleException e) {
-			}
+			stopSilently();
 			throw new IllegalStateException("Tomcat connector in failed state");
 		}
 	}
 
+	private void stopSilently() {
+		try {
+			this.tomcat.stop();
+		}
+		catch (LifecycleException ex) {
+		}
+	}
+
 	private void addPreviouslyRemovedConnectors() {
 		Service[] services = this.tomcat.getServer().findServices();
 		for (Service service : services) {

spring-boot/src/main/java/org/springframework/boot/context/web/ErrorPageFilter.java

@@ -77,14 +77,13 @@ class ErrorPageFilter extends AbstractConfigurableEmbeddedServletContainer imple
 	private final Map<Class<?>, String> exceptions = new HashMap<Class<?>, String>();
 
 	private final Map<Class<?>, Class<?>> subtypes = new HashMap<Class<?>, Class<?>>();
-	
-	private final OncePerRequestFilter delegate = new OncePerRequestFilter(
-			) {
-		
+
+	private final OncePerRequestFilter delegate = new OncePerRequestFilter() {
+
 		@Override
 		protected void doFilterInternal(HttpServletRequest request,
-				HttpServletResponse response, FilterChain chain)
-				throws ServletException, IOException {
+				HttpServletResponse response, FilterChain chain) throws ServletException,
+				IOException {
 			ErrorPageFilter.this.doFilter(request, response, chain);
 		}
 
@@ -92,13 +91,13 @@ class ErrorPageFilter extends AbstractConfigurableEmbeddedServletContainer imple
 
 	@Override
 	public void init(FilterConfig filterConfig) throws ServletException {
-		delegate.init(filterConfig);
+		this.delegate.init(filterConfig);
 	}
 
 	@Override
 	public void doFilter(ServletRequest request, ServletResponse response,
 			FilterChain chain) throws IOException, ServletException {
-		delegate.doFilter(request, response, chain);
+		this.delegate.doFilter(request, response, chain);
 	}
 
 	private void doFilter(HttpServletRequest request, HttpServletResponse response,

spring-boot/src/test/java/org/springframework/boot/bind/PropertiesConfigurationFactoryMapTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2012-2013 the original author or authors.
+ * Copyright 2012-2014 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

spring-boot/src/test/java/org/springframework/boot/context/web/ErrorPageFilterTests.java

@@ -16,11 +16,6 @@
 
 package org.springframework.boot.context.web;
 
-import static org.hamcrest.Matchers.equalTo;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
 import java.io.IOException;
 
 import javax.servlet.RequestDispatcher;
@@ -38,6 +33,11 @@ import org.springframework.mock.web.MockFilterConfig;
 import org.springframework.mock.web.MockHttpServletRequest;
 import org.springframework.mock.web.MockHttpServletResponse;
 
+import static org.hamcrest.Matchers.equalTo;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertThat;
+import static org.junit.Assert.assertTrue;
+
 /**
  * Tests for {@link ErrorPageFilter}.
  *
@@ -110,7 +110,7 @@ public class ErrorPageFilterTests {
 				super.doFilter(request, response);
 			}
 		};
-		filter.init(new MockFilterConfig("FILTER"));
+		this.filter.init(new MockFilterConfig("FILTER"));
 		this.filter.doFilter(this.request, this.response, this.chain);
 	}