diff --git a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/support/DefaultAmqpHeaderMapper.java b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/support/DefaultAmqpHeaderMapper.java
index d54f7caef9..d3091ac706 100644
--- a/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/support/DefaultAmqpHeaderMapper.java
+++ b/spring-integration-amqp/src/main/java/org/springframework/integration/amqp/support/DefaultAmqpHeaderMapper.java
@@ -166,7 +166,7 @@ public class DefaultAmqpHeaderMapper implements AmqpHeaderMapper {
 			// now map to the user-defined headers, if any, within the AMQP MessageProperties
 			Set<String> headerNames = headers.keySet();
 			for (String headerName : headerNames) {
-				if (this.shoudlMapHeader(headerName)){
+				if (this.shouldMapHeader(headerName)){
 					if (StringUtils.hasText(headerName) && !headerName.startsWith(AmqpHeaders.PREFIX)) {
 						Object value = headers.get(headerName);
 						if (value != null) {
@@ -191,7 +191,7 @@ public class DefaultAmqpHeaderMapper implements AmqpHeaderMapper {
 		}
 	}
 	
-	private boolean shoudlMapHeader(String headerName){
+	private boolean shouldMapHeader(String headerName){
 		return !headerName.equals(MessageHeaders.ERROR_CHANNEL) && 
 			   !headerName.equals(MessageHeaders.REPLY_CHANNEL) &&
 			   !headerName.equals(MessageHeaders.ID) &&