Fine-tune HTTP/RMI Invoker exception handling

Issue: SPR-15684
(cherry picked from commit 535103c)

spring-context/src/main/java/org/springframework/remoting/rmi/RemoteInvocationSerializingExporter.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2012 the original author or authors.
+ * Copyright 2002-2017 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.
@@ -107,7 +107,9 @@ public abstract class RemoteInvocationSerializingExporter extends RemoteInvocati
 	}
 
 	protected final Object getProxy() {
-		Assert.notNull(this.proxy, ClassUtils.getShortName(getClass()) + " has not been initialized");
+		if (this.proxy == null) {
+			throw new IllegalStateException(ClassUtils.getShortName(getClass()) + " has not been initialized");
+		}
 		return this.proxy;
 	}
 
@@ -142,7 +144,7 @@ public abstract class RemoteInvocationSerializingExporter extends RemoteInvocati
 		Object obj = ois.readObject();
 		if (!(obj instanceof RemoteInvocation)) {
 			throw new RemoteException("Deserialized object needs to be assignable to type [" +
-					RemoteInvocation.class.getName() + "]: " + obj);
+					RemoteInvocation.class.getName() + "]: " + ClassUtils.getDescriptiveType(obj));
 		}
 		return (RemoteInvocation) obj;
 	}

spring-context/src/main/java/org/springframework/remoting/support/RemoteExporter.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2012 the original author or authors.
+ * Copyright 2002-2017 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.
@@ -89,7 +89,7 @@ public abstract class RemoteExporter extends RemotingSupport {
 	 * @see RemoteInvocationTraceInterceptor
 	 */
 	public void setRegisterTraceInterceptor(boolean registerTraceInterceptor) {
-		this.registerTraceInterceptor = Boolean.valueOf(registerTraceInterceptor);
+		this.registerTraceInterceptor = registerTraceInterceptor;
 	}
 
 	/**
@@ -153,20 +153,23 @@ public abstract class RemoteExporter extends RemotingSupport {
 	protected Object getProxyForService() {
 		checkService();
 		checkServiceInterface();
+
 		ProxyFactory proxyFactory = new ProxyFactory();
 		proxyFactory.addInterface(getServiceInterface());
-		if (this.registerTraceInterceptor != null ?
-				this.registerTraceInterceptor.booleanValue() : this.interceptors == null) {
+
+		if (this.registerTraceInterceptor != null ? this.registerTraceInterceptor : this.interceptors == null) {
 			proxyFactory.addAdvice(new RemoteInvocationTraceInterceptor(getExporterName()));
 		}
 		if (this.interceptors != null) {
 			AdvisorAdapterRegistry adapterRegistry = GlobalAdvisorAdapterRegistry.getInstance();
-			for (int i = 0; i < this.interceptors.length; i++) {
-				proxyFactory.addAdvisor(adapterRegistry.wrap(this.interceptors[i]));
+			for (Object interceptor : this.interceptors) {
+				proxyFactory.addAdvisor(adapterRegistry.wrap(interceptor));
 			}
 		}
+
 		proxyFactory.setTarget(getService());
 		proxyFactory.setOpaque(true);
+
 		return proxyFactory.getProxy(getBeanClassLoader());
 	}
 

spring-web/src/main/java/org/springframework/remoting/httpinvoker/AbstractHttpInvokerRequestExecutor.java

@@ -32,6 +32,7 @@ import org.springframework.remoting.rmi.CodebaseAwareObjectInputStream;
 import org.springframework.remoting.support.RemoteInvocation;
 import org.springframework.remoting.support.RemoteInvocationResult;
 import org.springframework.util.Assert;
+import org.springframework.util.ClassUtils;
 
 /**
  * Abstract base implementation of the HttpInvokerRequestExecutor interface.
@@ -290,7 +291,7 @@ public abstract class AbstractHttpInvokerRequestExecutor implements HttpInvokerR
 		Object obj = ois.readObject();
 		if (!(obj instanceof RemoteInvocationResult)) {
 			throw new RemoteException("Deserialized object needs to be assignable to type [" +
-					RemoteInvocationResult.class.getName() + "]: " + obj);
+					RemoteInvocationResult.class.getName() + "]: " + ClassUtils.getDescriptiveType(obj));
 		}
 		return (RemoteInvocationResult) obj;
 	}

spring-web/src/main/java/org/springframework/remoting/httpinvoker/HttpComponentsHttpInvokerRequestExecutor.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2016 the original author or authors.
+ * Copyright 2002-2017 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.
@@ -263,10 +263,12 @@ public class HttpComponentsHttpInvokerRequestExecutor extends AbstractHttpInvoke
 	 */
 	protected HttpPost createHttpPost(HttpInvokerClientConfiguration config) throws IOException {
 		HttpPost httpPost = new HttpPost(config.getServiceUrl());
+
 		RequestConfig requestConfig = createRequestConfig(config);
 		if (requestConfig != null) {
 			httpPost.setConfig(requestConfig);
 		}
+
 		LocaleContext localeContext = LocaleContextHolder.getLocaleContext();
 		if (localeContext != null) {
 			Locale locale = localeContext.getLocale();
@@ -274,9 +276,11 @@ public class HttpComponentsHttpInvokerRequestExecutor extends AbstractHttpInvoke
 				httpPost.addHeader(HTTP_HEADER_ACCEPT_LANGUAGE, StringUtils.toLanguageTag(locale));
 			}
 		}
+
 		if (isAcceptGzipEncoding()) {
 			httpPost.addHeader(HTTP_HEADER_ACCEPT_ENCODING, ENCODING_GZIP);
 		}
+
 		return httpPost;
 	}
 
@@ -300,9 +304,10 @@ public class HttpComponentsHttpInvokerRequestExecutor extends AbstractHttpInvoke
 	}
 
 	private RequestConfig mergeRequestConfig(RequestConfig defaultRequestConfig) {
-		if (this.requestConfig == null) { // nothing to merge
+		if (this.requestConfig == null) {  // nothing to merge
 			return defaultRequestConfig;
 		}
+
 		RequestConfig.Builder builder = RequestConfig.copy(defaultRequestConfig);
 		int connectTimeout = this.requestConfig.getConnectTimeout();
 		if (connectTimeout >= 0) {

spring-web/src/main/java/org/springframework/remoting/httpinvoker/SimpleHttpInvokerRequestExecutor.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2014 the original author or authors.
+ * Copyright 2002-2017 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.
@@ -107,7 +107,8 @@ public class SimpleHttpInvokerRequestExecutor extends AbstractHttpInvokerRequest
 	protected HttpURLConnection openConnection(HttpInvokerClientConfiguration config) throws IOException {
 		URLConnection con = new URL(config.getServiceUrl()).openConnection();
 		if (!(con instanceof HttpURLConnection)) {
-			throw new IOException("Service URL [" + config.getServiceUrl() + "] is not an HTTP URL");
+			throw new IOException(
+					"Service URL [" + config.getServiceUrl() + "] does not resolve to an HTTP connection");
 		}
 		return (HttpURLConnection) con;
 	}
@@ -130,6 +131,7 @@ public class SimpleHttpInvokerRequestExecutor extends AbstractHttpInvokerRequest
 		if (this.readTimeout >= 0) {
 			connection.setReadTimeout(this.readTimeout);
 		}
+
 		connection.setDoOutput(true);
 		connection.setRequestMethod(HTTP_METHOD_POST);
 		connection.setRequestProperty(HTTP_HEADER_CONTENT_TYPE, getContentType());
@@ -142,6 +144,7 @@ public class SimpleHttpInvokerRequestExecutor extends AbstractHttpInvokerRequest
 				connection.setRequestProperty(HTTP_HEADER_ACCEPT_LANGUAGE, StringUtils.toLanguageTag(locale));
 			}
 		}
+
 		if (isAcceptGzipEncoding()) {
 			connection.setRequestProperty(HTTP_HEADER_ACCEPT_ENCODING, ENCODING_GZIP);
 		}