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

AMQP-175: upgrade top rabbit 2.5.0

Browse Source
This commit is contained in:
Dave Syer
2011-06-27 13:00:12 +01:00
parent 6f96dc857d
commit b90765a460
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

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