From 68b9d1ba7799d9fea32cfec73778edfe62baff72 Mon Sep 17 00:00:00 2001 From: Dave Syer Date: Tue, 28 Jun 2011 10:15:02 +0100 Subject: [PATCH] Fix Logger sample for changes in RC2 to headers --- .../rabbit/log4j/listener/AmqpLogMessageConverter.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/log4j/src/main/java/org/springframework/amqp/rabbit/log4j/listener/AmqpLogMessageConverter.java b/log4j/src/main/java/org/springframework/amqp/rabbit/log4j/listener/AmqpLogMessageConverter.java index 9493951..50afba6 100644 --- a/log4j/src/main/java/org/springframework/amqp/rabbit/log4j/listener/AmqpLogMessageConverter.java +++ b/log4j/src/main/java/org/springframework/amqp/rabbit/log4j/listener/AmqpLogMessageConverter.java @@ -24,8 +24,6 @@ import org.springframework.amqp.support.converter.AbstractMessageConverter; import org.springframework.amqp.support.converter.MessageConversionException; import org.springframework.util.CollectionUtils; -import com.rabbitmq.client.impl.LongString; - /** * @author tomas.lukosius@opencredo.com * @@ -75,10 +73,8 @@ public class AmqpLogMessageConverter extends AbstractMessageConverter { return null; } - String logger = new String( - ((LongString) headers.get(AmqpAppender.CATEGORY_NAME)).getBytes()); - String level = new String( - ((LongString) headers.get(AmqpAppender.CATEGORY_LEVEL)).getBytes()); + String logger = (String) headers.get(AmqpAppender.CATEGORY_NAME); + String level = (String) headers.get(AmqpAppender.CATEGORY_LEVEL); content = new AmqpLogMessage(logger, level, new String(message.getBody()), timestamp.getTime(), applicationId);