jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-11 03:49:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix the checkstyle warning

Browse Source
This commit is contained in:
von gosling
2020-11-23 10:37:35 +08:00
committed by GitHub
parent 50ee07b47b
commit 148945f6d6
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/apache/rocketmq/console/service/impl/TopicServiceImpl.java
View File

@@ -236,13 +236,13 @@ public class TopicServiceImpl extends AbstractCommonService implements TopicServ
@Override @Override
public SendResult sendTopicMessageRequest(SendTopicMessageRequest sendTopicMessageRequest) { public SendResult sendTopicMessageRequest(SendTopicMessageRequest sendTopicMessageRequest) {
DefaultMQProducer producer = null; DefaultMQProducer producer = null;
if(rMQConfigure.isACLEnabled()){ if (rMQConfigure.isACLEnabled()) {
producer = new DefaultMQProducer(new AclClientRPCHook(new SessionCredentials( producer = new DefaultMQProducer(new AclClientRPCHook(new SessionCredentials(
rMQConfigure.getAccessKey(), rMQConfigure.getAccessKey(),
rMQConfigure.getSecretKey() rMQConfigure.getSecretKey()
))); )));
producer.setProducerGroup(MixAll.SELF_TEST_PRODUCER_GROUP); producer.setProducerGroup(MixAll.SELF_TEST_PRODUCER_GROUP);
}else{ } else {
producer = new DefaultMQProducer(MixAll.SELF_TEST_PRODUCER_GROUP); producer = new DefaultMQProducer(MixAll.SELF_TEST_PRODUCER_GROUP);
} }