diff --git a/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsDestinationPollingSource.java b/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsDestinationPollingSource.java index 3fcc23c9e9..efa09f61cf 100644 --- a/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsDestinationPollingSource.java +++ b/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsDestinationPollingSource.java @@ -78,7 +78,7 @@ public class JmsDestinationPollingSource extends AbstractJmsTemplateBasedAdapter } try { // Map headers - Map mappedHeaders = this.getHeaderMapper().toHeaders(jmsMessage); + Map mappedHeaders = (Map) this.getHeaderMapper().toHeaders(jmsMessage); MessageConverter converter = this.getJmsTemplate().getMessageConverter(); Object convertedObject = converter.fromMessage(jmsMessage); if (convertedObject instanceof Message) {