From c00f588af77ac3f2a65dc432410e8b4b141cb30e Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@vmware.com>
Date: Wed, 26 Jul 2023 13:01:30 -0400
Subject: [PATCH] GH-2495: Add maxInboundMessageBodySize to RCFB

Resolves https://github.com/spring-projects/spring-amqp/issues/2495

Although the factory bean has...

```java
	/**
	 * Access the connection factory to set any other properties not supported by
	 * this factory bean.
	 * @return the connection factory.
	 * @since 1.7.14
	 */
	public ConnectionFactory getRabbitConnectionFactory() {
```

...this new CF property could be a breaking change for users that configure the
factory bean using XML.

**cherry-pick to 2.4.x**

(cherry picked from commit a18470d9f85ff0513b7f7c0482e04bb92b048623)
---
 .../connection/RabbitConnectionFactoryBean.java    | 14 ++++++++++++--
 .../amqp/rabbit/connection/SSLConnectionTests.java |  4 +++-
 2 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitConnectionFactoryBean.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitConnectionFactoryBean.java
index 08b1dfd470..d12361ee1d 100644
--- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitConnectionFactoryBean.java
+++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitConnectionFactoryBean.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2020 the original author or authors.
+ * Copyright 2002-2023 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.
@@ -66,7 +66,7 @@
  * using the supplied properties and intializes key and trust manager factories, using
  * algorithm {@code SunX509} by default. These are then used to initialize an
  * {@link SSLContext} using the {@link #setSslAlgorithm(String) sslAlgorithm} (default
- * TLSv1.1).
+ * TLSv1.2, falling back to TLSv1.1, if 1.2 is not available).
  * <p>
  * Override {@link #createSSLContext()} to create and/or perform further modification of
  * the context.
@@ -672,6 +672,16 @@ public void setEnableHostnameVerification(boolean enable) {
 		this.enableHostnameVerification = enable;
 	}
 
+	/**
+	 * Set the maximum body size of inbound (received) messages in bytes.
+	 * @param maxInboundMessageBodySize the maximum size.
+	 * @since 2.4.15
+	 * @see com.rabbitmq.client.ConnectionFactory#setMaxInboundMessageBodySize(int)
+	 */
+	public void setMaxInboundMessageBodySize(int maxInboundMessageBodySize) {
+		this.connectionFactory.setMaxInboundMessageBodySize(maxInboundMessageBodySize);
+	}
+
 	protected String getKeyStoreAlgorithm() {
 		return this.keyStoreAlgorithm;
 	}
diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/SSLConnectionTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/SSLConnectionTests.java
index d3c50a58de..e4e4f926be 100644
--- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/SSLConnectionTests.java
+++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/connection/SSLConnectionTests.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2014-2019 the original author or authors.
+ * Copyright 2014-2023 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.
@@ -76,6 +76,7 @@ public void test() throws Exception {
 	@Test
 	public void testAlgNoProps() throws Exception {
 		RabbitConnectionFactoryBean fb = new RabbitConnectionFactoryBean();
+		fb.setMaxInboundMessageBodySize(1000);
 		ConnectionFactory rabbitCf = spy(TestUtils.getPropertyValue(fb, "connectionFactory", ConnectionFactory.class));
 		new DirectFieldAccessor(fb).setPropertyValue("connectionFactory", rabbitCf);
 		fb.setUseSSL(true);
@@ -83,6 +84,7 @@ public void testAlgNoProps() throws Exception {
 		fb.afterPropertiesSet();
 		fb.getObject();
 		verify(rabbitCf).useSslProtocol(Mockito.any(SSLContext.class));
+		assertThat(rabbitCf).hasFieldOrPropertyWithValue("maxInboundMessageBodySize", 1000);
 	}
 
 	@Test