Fix DEBUG Logging for Projection

Don't Log Converted Message With Projection

`toString()` cannot be invoked on the payload proxy created by
the projection factory.

Increase memory for builds.

* Unlike Kafka, we can't use the converter type to determine if projection was used.

* Add null check.

Author: garyrussell

build.gradle

@@ -236,6 +236,9 @@ subprojects { subproject ->
     compileKotlin.dependsOn updateCopyrights
 
 	test {
+		maxHeapSize = '2g'
+		jvmArgs '-XX:+HeapDumpOnOutOfMemoryError'
+
 		testLogging {
 			events "skipped", "failed"
 			showStandardStreams = project.hasProperty("showStandardStreams") ?: false

gradle.properties

@@ -1,4 +1,5 @@
 version=2.3.12-SNAPSHOT
+org.gradle.jvmargs=-Xms512m -Xmx4g -XX:MaxPermSize=1024m -XX:MaxMetaspaceSize=1g
 org.gradlee.caching=true
 org.gradle.daemon=true
 org.gradle.parallel=true

spring-amqp/src/main/java/org/springframework/amqp/core/MessageProperties.java

@@ -128,6 +128,8 @@ public class MessageProperties implements Serializable {
 
 	private boolean lastInBatch;
 
+	private boolean projectionUsed;
+
 	private transient Type inferredArgumentType;
 
 	private transient Method targetMethod;
@@ -552,6 +554,26 @@ public void setLastInBatch(boolean lastInBatch) {
 		this.lastInBatch = lastInBatch;
 	}
 
+	/**
+	 * Get an internal flag used to communicate that conversion used projection; always
+	 * false at the application level.
+	 * @return true if projection was used.
+	 * @since 2.2.20
+	 */
+	public boolean isProjectionUsed() {
+		return this.projectionUsed;
+	}
+
+	/**
+	 * Set an internal flag used to communicate that conversion used projection; always false
+	 * at the application level.
+	 * @param projectionUsed true for projection.
+	 * @since 2.2.20
+	 */
+	public void setProjectionUsed(boolean projectionUsed) {
+		this.projectionUsed = projectionUsed;
+	}
+
 	/**
 	 * Return the x-death header.
 	 * @return the header.

spring-amqp/src/main/java/org/springframework/amqp/support/converter/AbstractJackson2MessageConverter.java

@@ -305,6 +305,7 @@ private Object convertContent(Message message, Object conversionHint, MessagePro
 		if (inferredType != null && this.useProjectionForInterfaces && inferredType.isInterface()
 				&& !inferredType.getRawClass().getPackage().getName().startsWith("java.util")) { // List etc
 			content = this.projectingConverter.convert(message, inferredType.getRawClass());
+			properties.setProjectionUsed(true);
 		}
 		else if (inferredType != null && this.alwaysConvertToInferredType) {
 			content = tryConverType(message, encoding, inferredType);

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/adapter/MessagingMessageListenerAdapter.java

@@ -183,7 +183,11 @@ private void handleException(org.springframework.amqp.core.Message amqpMessage,
 	protected void invokeHandlerAndProcessResult(@Nullable org.springframework.amqp.core.Message amqpMessage,
 			Channel channel, Message<?> message) throws Exception { // NOSONAR
 
-		if (logger.isDebugEnabled()) {
+		boolean projectionUsed = amqpMessage == null ? false : amqpMessage.getMessageProperties().isProjectionUsed();
+		if (projectionUsed) {
+			amqpMessage.getMessageProperties().setProjectionUsed(false);
+		}
+		if (logger.isDebugEnabled() && !projectionUsed) {
 			logger.debug("Processing [" + message + "]");
 		}
 		InvocationResult result = null;