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

Fix Logger sample for changes in RC2 to headers

Browse Source
This commit is contained in:
Dave Syer
2011-06-28 10:15:02 +01:00
parent b90765a460
commit 68b9d1ba77
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
log4j/src/main/java/org/springframework/amqp/rabbit/log4j/listener/AmqpLogMessageConverter.java
View File

@@ -24,8 +24,6 @@ import org.springframework.amqp.support.converter.AbstractMessageConverter;
import org.springframework.amqp.support.converter.MessageConversionException; import org.springframework.amqp.support.converter.MessageConversionException;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import com.rabbitmq.client.impl.LongString;
/** /**
* @author tomas.lukosius@opencredo.com * @author tomas.lukosius@opencredo.com
* *
@@ -75,10 +73,8 @@ public class AmqpLogMessageConverter extends AbstractMessageConverter {
return null; return null;
} }
String logger = new String( String logger = (String) headers.get(AmqpAppender.CATEGORY_NAME);
((LongString) headers.get(AmqpAppender.CATEGORY_NAME)).getBytes()); String level = (String) headers.get(AmqpAppender.CATEGORY_LEVEL);
String level = new String(
((LongString) headers.get(AmqpAppender.CATEGORY_LEVEL)).getBytes());
content = new AmqpLogMessage(logger, level, new String(message.getBody()), timestamp.getTime(), content = new AmqpLogMessage(logger, level, new String(message.getBody()), timestamp.getTime(),
applicationId); applicationId);