AMQP-713: add channel RPC timeout setting

https://jira.spring.io/browse/AMQP-713
2017-02-20 11:52:27 +01:00
parent 2c7c1525cf
commit bb60692624
1 changed files with 9 additions and 0 deletions
--- 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;