conf

whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/rocketmq/BrokerStartup.java

@@ -9,6 +9,6 @@ public class BrokerStartup {
         String classpath = BrokerStartup.class.getResource("/").getPath();
         args = new String[] {"-c", classpath + "conf.properties"};
         org.apache.rocketmq.broker.BrokerStartup.main(args);
-        System.out.println("Broker started.");
+        System.out.println("Broker started. name: " + org.apache.rocketmq.broker.BrokerStartup.properties.getProperty("brokerName"));
     }
 }

whatsmars-mq/src/main/resources/conf.properties

-rocketmqHome=D:\\github\\incubator-rocketmq\\distribution
+rocketmqHome=D:/github/incubator-rocketmq/distribution
 namesrvAddr=127.0.0.1:9876
+
+brokerName=broker-a
+listenPort=10911
 mapedFileSizeCommitLog=52428800
 mapedFileSizeConsumeQueue=30000
\ No newline at end of file