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

GH-1332 Fixed ClassCastException

Browse Source 
Removed casting to byte[] in SendingHandler.serializeAndEmbedHeadersIfApplicable(..)

Resolves #1332
This commit is contained in:
Oleg Zhurakousky
2018-03-30 16:57:04 -04:00
parent 3d0811b701
commit a48739e905
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -729,7 +729,7 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
@SuppressWarnings("deprecation")
private Message<?> serializeAndEmbedHeadersIfApplicable(Message<?> message) throws Exception {
MessageValues transformed = serializePayloadIfNecessary(message);
byte[] payload;
Object payload;
if (this.embedHeaders) {
Object contentType = transformed.get(MessageHeaders.CONTENT_TYPE);
// transform content type headers to String, so that they can be properly
@@ -744,7 +744,7 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
payload = EmbeddedHeaderUtils.embedHeaders(transformed, this.embeddedHeaders);
}
else {
payload = (byte[]) transformed.getPayload();
payload = transformed.getPayload();
}
return getMessageBuilderFactory().withPayload(payload).copyHeaders(transformed.getHeaders()).build();
}