Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQP-165: explicitly destory connection factory in Log4j Appender

Browse Source
This commit is contained in:
Dave Syer
2011-04-27 13:42:59 +01:00
parent 8c90ee6eac
commit 33a75e72d1
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/log4j/AmqpAppender.java
View File

@@ -396,6 +396,9 @@ public class AmqpAppender extends AppenderSkeleton {
senderPool.shutdownNow();
senderPool = null;
}
if (null != connectionFactory) {
connectionFactory.destroy();
}
}
public boolean requiresLayout() {
@@ -408,7 +411,7 @@ public class AmqpAppender extends AppenderSkeleton {
protected class EventSender implements Runnable {
public void run() {
try {
RabbitTemplate rabbitTmpl = new RabbitTemplate(connectionFactory);
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
while (true) {
final Event event = events.take();
LoggingEvent logEvent = event.getEvent();
@@ -460,7 +463,7 @@ public class AmqpAppender extends AppenderSkeleton {
// Send a message
String routingKey = routingKeyLayout.format(logEvent);
try {
rabbitTmpl
rabbitTemplate
.send(exchangeName, routingKey, new Message(msgBody.toString().getBytes(), amqpProps));
} catch (AmqpException e) {
int retries = event.incrementRetries();