AMQP-156: remove connectionTimeout from AmqpAppender

This commit is contained in:
Dave Syer
2011-04-20 17:58:30 +01:00
parent 8ffa9de28d
commit 96de0bf559

View File

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