study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

close #234

Browse Source
This commit is contained in:
fangjian0423 2019-01-09 02:52:36 +08:00
parent 0cb0f7516f
commit 2a05e7ff5a
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
View File

@ -98,6 +98,9 @@ public class RocketMQMessageHandler extends AbstractMessageHandler implements Li
producer = new DefaultMQProducer(destination); producer = new DefaultMQProducer(destination);
} }
producer.setVipChannelEnabled(
producerProperties.getExtension().getVipChannelEnabled());
Optional.ofNullable(instrumentationManager).ifPresent(manager -> { Optional.ofNullable(instrumentationManager).ifPresent(manager -> {
producerInstrumentation = manager.getProducerInstrumentation(destination); producerInstrumentation = manager.getProducerInstrumentation(destination);
manager.addHealthInstrumentation(producerInstrumentation); manager.addHealthInstrumentation(producerInstrumentation);

10
spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/properties/RocketMQProducerProperties.java
View File

@ -45,6 +45,8 @@ public class RocketMQProducerProperties {
*/ */
private String transactionCheckListener; private String transactionCheckListener;
private Boolean vipChannelEnabled = true;
public Boolean getEnabled() { public Boolean getEnabled() {
return enabled; return enabled;
} }
@ -84,4 +86,12 @@ public class RocketMQProducerProperties {
public void setTransactionCheckListener(String transactionCheckListener) { public void setTransactionCheckListener(String transactionCheckListener) {
this.transactionCheckListener = transactionCheckListener; this.transactionCheckListener = transactionCheckListener;
} }
public Boolean getVipChannelEnabled() {
return vipChannelEnabled;
}
public void setVipChannelEnabled(Boolean vipChannelEnabled) {
this.vipChannelEnabled = vipChannelEnabled;
}
} }