From 96de0bf559eaa5633da327b58b067629aad4a903 Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@vmware.com>
Date: Wed, 20 Apr 2011 17:58:30 +0100
Subject: [PATCH] AMQP-156: remove connectionTimeout from AmqpAppender

---
 .../amqp/rabbit/log4j/AmqpAppender.java        | 18 ------------------
 1 file changed, 18 deletions(-)

diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/log4j/AmqpAppender.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/log4j/AmqpAppender.java
index 8da7e63f..d0119e1b 100644
--- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/log4j/AmqpAppender.java
+++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/log4j/AmqpAppender.java
@@ -61,7 +61,6 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate;
  *   log4j.appender.amqp.username=guest
  *   log4j.appender.amqp.password=guest
  *   log4j.appender.amqp.virtualHost=/
- *   log4j.appender.amqp.replyTimeout=0
  *   #-------------------------------
  *   ## Exchange name and type
  *   #-------------------------------
@@ -139,10 +138,6 @@ public class AmqpAppender extends AppenderSkeleton {
 	 * Whether or not we've tried to declare this exchange yet.
 	 */
 	private AtomicBoolean exchangeDeclared = new AtomicBoolean(false);
-	/**
-	 * How long to wait for a connection to time out.
-	 */
-	private int replyTimeout = 0;
 	/**
 	 * Configuration arbitrary application ID.
 	 */
@@ -288,14 +283,6 @@ public class AmqpAppender extends AppenderSkeleton {
 		this.declareExchange = declareExchange;
 	}
 
-	public int getReplyTimeout() {
-		return replyTimeout;
-	}
-
-	public void setReplyTimeout(int replyTimeout) {
-		this.replyTimeout = replyTimeout;
-	}
-
 	public String getContentType() {
 		return contentType;
 	}
@@ -422,11 +409,6 @@ public class AmqpAppender extends AppenderSkeleton {
 		public void run() {
 			try {
 				RabbitTemplate rabbitTmpl = new RabbitTemplate(connectionFactory);
-				if (replyTimeout > 0) {
-					// Set a reply timeout if one's been specified by the user
-					// leave it off by default
-					rabbitTmpl.setReplyTimeout(replyTimeout);
-				}
 				while (true) {
 					final Event event = events.take();
 					LoggingEvent logEvent = event.getEvent();