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

convertPayloadIfNecessary change to use Value Class Type

Browse Source 
convertPayloadIfNecessary is using getProducerMetadata().getKeyClassType() when it should use getProducerMetadata().getValueClassType()
This commit is contained in:
Gamal
2015-09-24 15:51:28 -05:00
committed by Artem Bilan
parent 9b49e9a673
commit 21600a275d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ProducerConfiguration.java
View File

@@ -125,7 +125,7 @@ public class ProducerConfiguration<K, V> {
private V convertPayloadIfNecessary(Object messagePayload) {
if (messagePayload != null) {
if (getProducerMetadata().getKeyClassType().isAssignableFrom(
if (getProducerMetadata().getValueClassType().isAssignableFrom(
messagePayload.getClass())) {
return getProducerMetadata().getValueClassType().cast(messagePayload);
}