From bb60692624c466cb29907572a233b5e96ec390ef Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?= <acogoluegnes@gmail.com>
Date: Mon, 20 Feb 2017 11:52:27 +0100
Subject: [PATCH] AMQP-713: add channel RPC timeout setting

https://jira.spring.io/browse/AMQP-713
---
 .../rabbit/connection/RabbitConnectionFactoryBean.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

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 bb28db77..d13f1bf5 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
@@ -589,6 +589,15 @@ public class RabbitConnectionFactoryBean extends AbstractFactoryBean<ConnectionF
 		this.connectionFactory.setTopologyRecoveryEnabled(topologyRecoveryEnabled);
 	}
 
+	/**
+	 * @param channelRpcTimeout continuation timeout for RPC calls in channels
+	 * @see com.rabbitmq.client.ConnectionFactory#setChannelRpcTimeout(int)
+	 * @since 2.0
+	 */
+	public void setChannelRpcTimeout(int channelRpcTimeout) {
+		this.connectionFactory.setChannelRpcTimeout(channelRpcTimeout);
+	}
+
 	@Override
 	public Class<?> getObjectType() {
 		return ConnectionFactory.class;