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();