SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Correct Rabbit defaults for headers

Browse Source
This commit is contained in:
Marius Bogoevici
2016-03-17 01:58:45 -04:00
parent 29bafe9807
commit af733faf18
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitConsumerProperties.java
View File

@@ -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;
}
}

2
spring-cloud-stream-binders/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitProducerProperties.java
View File

@@ -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;