SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add comment to embedded header decode error log

Browse Source
This commit is contained in:
Gary Russell
2017-11-08 10:16:52 -05:00
parent 62c8513197
commit b9884ae71a
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
View File

@@ -283,7 +283,14 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
messageValues = EmbeddedHeaderUtils.extractHeaders((Message<byte[]>) message, true);
}
catch (Exception e) {
logger.debug(EmbeddedHeaderUtils.decodeExceptionMessage(message),e);
/*
* debug() rather then error() since we don't know for sure that it
* really is a message with embedded headers, it just meets the
* criteria in EmbeddedHeaderUtils.mayHaveEmbeddedHeaders().
*/
if (logger.isDebugEnabled()) {
logger.debug(EmbeddedHeaderUtils.decodeExceptionMessage(message),e);
}
messageValues = new MessageValues(message);
}
return messageValues.toMessage();