docs: add comprehensive English Javadoc

Author: loong10k

src/main/java/org/apache/rocketmq/spring/boot/RocketmqPullConsumerAutoConfiguration.java

@@ -76,6 +76,10 @@ public class RocketmqPullConsumerAutoConfiguration  implements ApplicationContex
 	 */
 	@Bean
 	@ConditionalOnMissingBean
+    /**
+     * <p>Allocate message queue strategy.</p>
+     * @return the allocate message queue strategy
+     */
 	public AllocateMessageQueueStrategy allocateMessageQueueStrategy() {
 		return new AllocateMessageQueueConsistentHash();
 	}
@@ -161,6 +165,9 @@ public DefaultMQPullConsumer pullConsumer(RocketmqPullConsumerProperties propert
 		 * not yet registered.
 		 */
 		Executors.newScheduledThreadPool(1).schedule(new Thread() {
+    /**
+     * <p>Run.</p>
+     */
 			public void run() {
 				try {
 
@@ -191,6 +198,11 @@ public void run() {
 
 	@Bean
 	@ConditionalOnProperty(prefix = RocketmqPullConsumerProperties.PREFIX, name = "schedulable", havingValue = "true")
+    /**
+     * <p>Schedule pull consumer.</p>
+     * @param properties
+     * @return the schedule pull consumer
+     */
 	public MQPullConsumerScheduleService schedulePullConsumer(RocketmqPullConsumerProperties properties) throws MQClientException {
 
 		if (StringUtils.isEmpty(properties.getConsumerGroup())) {
@@ -238,6 +250,9 @@ public MQPullConsumerScheduleService schedulePullConsumer(RocketmqPullConsumerPr
 		 * not yet registered.
 		 */
 		Executors.newScheduledThreadPool(1).schedule(new Thread() {
+    /**
+     * <p>Run.</p>
+     */
 			public void run() {
 				try {
 
@@ -267,15 +282,28 @@ public void run() {
 	}
 
 	@Bean
+    /**
+     * <p>Rocketmq consumer template.</p>
+     * @param consumer
+     * @return the rocketmq consumer template
+     */
 	public RocketmqPullConsumerTemplate rocketmqConsumerTemplate(MQPullConsumer consumer) throws MQClientException {
 		return new RocketmqPullConsumerTemplate(consumer);
 	}
 
 	@Override
+    /**
+     * <p>Sets the application context.</p>
+     * @param applicationContext
+     */
 	public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
 		this.applicationContext = applicationContext;
 	}
 
+    /**
+     * <p>Returns the application context.</p>
+     * @return the get application context
+     */
 	public ApplicationContext getApplicationContext() {
 		return applicationContext;
 	}

src/main/java/org/apache/rocketmq/spring/boot/RocketmqPushConsumerAutoConfiguration.java

@@ -73,12 +73,20 @@ public class RocketmqPushConsumerAutoConfiguration  {
 
 	@Bean
 	@ConditionalOnMissingBean
+    /**
+     * <p>Message listener concurrently.</p>
+     * @return the message listener concurrently
+     */
 	public MessageListenerConcurrently messageListenerConcurrently() {
 		return new DefaultMessageListenerConcurrently();
 	}
 
 	@Bean
 	@ConditionalOnMissingBean
+    /**
+     * <p>Message listener orderly.</p>
+     * @return the message listener orderly
+     */
 	public MessageListenerOrderly messageListenerOrderly() {
 		return new DefaultMessageListenerOrderly();
 	}
@@ -89,6 +97,10 @@ public MessageListenerOrderly messageListenerOrderly() {
 	 */
 	@Bean
 	@ConditionalOnMissingBean
+    /**
+     * <p>Allocate message queue strategy.</p>
+     * @return the allocate message queue strategy
+     */
 	public AllocateMessageQueueStrategy allocateMessageQueueStrategy() {
 		return new AllocateMessageQueueConsistentHash();
 	}
@@ -139,6 +151,10 @@ public void configure(DefaultMQPushConsumer consumer, RocketmqPushConsumerProper
 
 	@Bean
 	@ConditionalOnMissingBean
+    /**
+     * <p>Default sub provider.</p>
+     * @return the default sub provider
+     */
 	public SubscriptionProvider defaultSubProvider() {
 		return new DefaultSubscriptionProvider();
 	}
@@ -246,6 +262,9 @@ public DefaultMQPushConsumer pushConsumer(RocketmqPushConsumerProperties propert
 			 * its listener is not yet registered.
 			 */
 			Executors.newScheduledThreadPool(1).schedule(new Thread() {
+    /**
+     * <p>Run.</p>
+     */
 				public void run() {
 					try {
 
@@ -280,6 +299,11 @@ public void run() {
 	}
 
 	@Bean
+    /**
+     * <p>Rocketmq consumer template.</p>
+     * @param consumer
+     * @return the rocketmq consumer template
+     */
 	public RocketmqPushConsumerTemplate rocketmqConsumerTemplate(MQPushConsumer consumer) throws MQClientException {
 		return new RocketmqPushConsumerTemplate(consumer);
 	}