INT-2016 fixed the typo in the method name
This commit is contained in:
@@ -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) &&
|
||||
|
||||
Reference in New Issue
Block a user