GH-1463: RabbitTemplate.logReceived() Protected

Resolves #1463

**cherry-pick to 2.4.x**

Author: garyrussell

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java

@@ -1222,7 +1222,7 @@ else if (isChannelTransacted()) {
 			}
 			return null;
 		}, obtainTargetConnectionFactory(this.receiveConnectionFactorySelectorExpression, queueName));
-		logReceived(message);
+		logReceived("Received: ", message);
 		return message;
 	}
 
@@ -1261,7 +1261,7 @@ else if (isChannelTransacted()) {
 				return buildMessageFromDelivery(delivery);
 			}
 		}, obtainTargetConnectionFactory(this.receiveConnectionFactorySelectorExpression, null));
-		logReceived(message);
+		logReceived("Received: ", message);
 		return message;
 	}
 
@@ -1412,7 +1412,7 @@ else if (channelTransacted) {
 				receiveMessage = buildMessageFromDelivery(delivery);
 			}
 		}
-		logReceived(receiveMessage);
+		logReceived("Received: ", receiveMessage);
 		return receiveMessage;
 	}
 
@@ -1467,12 +1467,21 @@ private Delivery consumeDelivery(Channel channel, String queueName, long timeout
 		return delivery;
 	}
 
-	private void logReceived(@Nullable Message message) {
-		if (message == null) {
-			logger.debug("Received no message");
-		}
-		else if (logger.isDebugEnabled()) {
-			logger.debug("Received: " + message);
+	/**
+	 * Log a received message. The default implementation logs the full message at DEBUG
+	 * level. Override this method to change that behavior.
+	 * @param prefix a prefix, e.g. "Received: " or "Reply: ".
+	 * @param message the message.
+	 * @since 2.4.6
+	 */
+	protected void logReceived(String prefix, @Nullable Message message) {
+		if (logger.isDebugEnabled()) {
+			if (message == null) {
+				logger.debug(prefix + "no message");
+			}
+			else {
+				logger.debug(prefix + message);
+			}
 		}
 	}
 
@@ -2091,9 +2100,7 @@ private Message exchangeMessages(final String exchange, final String routingKey,
 		}
 		doSend(channel, exchange, routingKey, message, mandatory, correlationData);
 		reply = this.replyTimeout < 0 ? pendingReply.get() : pendingReply.get(this.replyTimeout, TimeUnit.MILLISECONDS);
-		if (this.logger.isDebugEnabled()) {
-			this.logger.debug("Reply: " + reply);
-		}
+		logReceived("Reply: ", reply);
 		if (reply == null) {
 			replyTimedOut(message.getMessageProperties().getCorrelationId());
 		}