diff --git a/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitConsumerProperties.java b/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitConsumerProperties.java index 62b72b097..3a3775e7b 100644 --- a/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitConsumerProperties.java +++ b/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitConsumerProperties.java @@ -47,7 +47,7 @@ public class RabbitConsumerProperties extends ConsumerProperties { private boolean requeueRejected = true; - private String replyHeaderPatterns; + private String[] replyHeaderPatterns = new String[] {"STANDARD_REPLY_HEADERS", "*"}; public String getPrefix() { return prefix; @@ -138,11 +138,11 @@ public class RabbitConsumerProperties extends ConsumerProperties { this.requeueRejected = requeueRejected; } - public String getReplyHeaderPatterns() { + public String[] getReplyHeaderPatterns() { return replyHeaderPatterns; } - public void setReplyHeaderPatterns(String replyHeaderPatterns) { + public void setReplyHeaderPatterns(String[] replyHeaderPatterns) { this.replyHeaderPatterns = replyHeaderPatterns; } } diff --git a/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitProducerProperties.java b/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitProducerProperties.java index cd88f963e..6bdbe9a0c 100644 --- a/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitProducerProperties.java +++ b/spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitProducerProperties.java @@ -42,7 +42,7 @@ public class RabbitProducerProperties extends ProducerProperties { private MessageDeliveryMode deliveryMode = MessageDeliveryMode.PERSISTENT; - private String[] replyHeaderPatterns = new String[] {"STANDARD_REQUEST_HEADERS", "*"}; + private String[] replyHeaderPatterns = new String[] {"STANDARD_REPLY_HEADERS", "*"}; public String getPrefix() { return prefix;