Fix Method Complexity

Author: garyrussell

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

@@ -954,27 +954,33 @@ protected boolean useDirectReplyTo() {
 				});
 			}
 			catch (AmqpConnectException | AmqpIOException ex) {
-				Throwable cause = ex;
-				while (cause != null && !(cause instanceof ShutdownSignalException)) {
-					cause = cause.getCause();
+				if (shouldRethrow(ex)) {
+					throw ex;
 				}
-				if (cause != null && RabbitUtils.isPassiveDeclarationChannelClose((ShutdownSignalException) cause)) {
-					if (logger.isWarnEnabled()) {
-						logger.warn("Broker does not support fast replies via 'amq.rabbitmq.reply-to', temporary "
-								+ "queues will be used: " + cause.getMessage() + ".");
-					}
-					this.replyAddress = null;
-					return false;
-				}
-				if (logger.isDebugEnabled()) {
-					logger.debug("IO error, deferring directReplyTo detection: " + ex.toString());
-				}
-				throw ex;
 			}
 		}
 		return false;
 	}
 
+	private boolean shouldRethrow(AmqpException ex) {
+		Throwable cause = ex;
+		while (cause != null && !(cause instanceof ShutdownSignalException)) {
+			cause = cause.getCause();
+		}
+		if (cause != null && RabbitUtils.isPassiveDeclarationChannelClose((ShutdownSignalException) cause)) {
+			if (logger.isWarnEnabled()) {
+				logger.warn("Broker does not support fast replies via 'amq.rabbitmq.reply-to', temporary "
+						+ "queues will be used: " + cause.getMessage() + ".");
+			}
+			this.replyAddress = null;
+			return false;
+		}
+		if (logger.isDebugEnabled()) {
+			logger.debug("IO error, deferring directReplyTo detection: " + ex.toString());
+		}
+		return true;
+	}
+
 	@Override
 	public void send(Message message) throws AmqpException {
 		send(this.exchange, this.routingKey, message);