| | |
| | | import com.google.common.collect.Lists; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; |
| | | import org.apache.rocketmq.common.UtilAll; |
| | | //import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; |
| | | //import org.apache.rocketmq.common.UtilAll; |
| | | import com.qianwen.smartman.common.constant.CommonConstant; |
| | | import com.qianwen.smartman.common.constant.TenantConstant; |
| | | import com.qianwen.core.tool.node.INode; |
| | |
| | | |
| | | |
| | | public class CommonUtil { |
| | | /* |
| | | public static String changeInstanceNameToPID(DefaultMQPushConsumer consumer) { |
| | | String instanceName = consumer.getInstanceName(); |
| | | if ("DEFAULT".equals(consumer.getInstanceName())) { |
| | | instanceName = UtilAll.getPid() + "#" + System.nanoTime(); |
| | | } |
| | | return instanceName; |
| | | } |
| | | }*/ |
| | | |
| | | public static int initCapacity(int size) { |
| | | return (int) ((size / 0.75d) + 1.0d); |