提交 e14f66ea 编写于 作者: C chenrl

fix some nonconformity after checkstyle

上级 f77d7fee
...@@ -94,7 +94,7 @@ public class ClientConfig { ...@@ -94,7 +94,7 @@ public class ClientConfig {
public void changeInstanceNameToPID() { public void changeInstanceNameToPID() {
if (this.instanceName.equals("DEFAULT")) { if (this.instanceName.equals("DEFAULT")) {
this.instanceName = UtilAll.getPid()+ "#" + System.nanoTime(); this.instanceName = UtilAll.getPid() + "#" + System.nanoTime();
} }
} }
......
...@@ -34,7 +34,7 @@ public class NameServerAddressUtils { ...@@ -34,7 +34,7 @@ public class NameServerAddressUtils {
if (StringUtils.isEmpty(endpoint)) { if (StringUtils.isEmpty(endpoint)) {
return null; return null;
} }
return endpoint.substring(endpoint.lastIndexOf("/")+1, endpoint.indexOf('.')); return endpoint.substring(endpoint.lastIndexOf("/") + 1, endpoint.indexOf('.'));
} }
public static String getNameSrvAddrFromNamesrvEndpoint(String nameSrvEndpoint) { public static String getNameSrvAddrFromNamesrvEndpoint(String nameSrvEndpoint) {
......
...@@ -16,12 +16,9 @@ ...@@ -16,12 +16,9 @@
*/ */
package org.apache.rocketmq.example.ordermessage; package org.apache.rocketmq.example.ordermessage;
import java.io.UnsupportedEncodingException;
import java.util.List;
import org.apache.rocketmq.client.exception.MQBrokerException; import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.MQProducer;
import org.apache.rocketmq.client.producer.MessageQueueSelector; import org.apache.rocketmq.client.producer.MessageQueueSelector;
import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.common.message.Message;
...@@ -29,6 +26,9 @@ import org.apache.rocketmq.common.message.MessageQueue; ...@@ -29,6 +26,9 @@ import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.remoting.common.RemotingHelper; import org.apache.rocketmq.remoting.common.RemotingHelper;
import org.apache.rocketmq.remoting.exception.RemotingException; import org.apache.rocketmq.remoting.exception.RemotingException;
import java.io.UnsupportedEncodingException;
import java.util.List;
public class Producer { public class Producer {
public static void main(String[] args) throws UnsupportedEncodingException { public static void main(String[] args) throws UnsupportedEncodingException {
try { try {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册