Fix bugs on example

spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/rocketmq/RocketMQBusApplication.java

@@ -16,15 +16,19 @@
  */
 package org.springframework.cloud.alibaba.cloud.examples.rocketmq;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.boot.WebApplicationType;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.cloud.bus.event.AckRemoteApplicationEvent;
 import org.springframework.cloud.bus.jackson.RemoteApplicationEventScan;
 import org.springframework.context.ApplicationEventPublisher;
-import org.springframework.context.annotation.Bean;
 import org.springframework.context.event.EventListener;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 
 /**
  * RocketMQ Bus Spring Application
@@ -32,33 +36,45 @@ import org.springframework.context.event.EventListener;
  * @author <a href="mailto:mercyblitz@gmail.com">Mercy</a>
  * @since 0.2.1
  */
+@RestController
 @EnableAutoConfiguration
 @RemoteApplicationEventScan(basePackages = "org.springframework.cloud.alibaba.cloud.examples.rocketmq")
 public class RocketMQBusApplication {
 
     public static void main(String[] args) {
         new SpringApplicationBuilder(RocketMQBusApplication.class)
+                .properties("server.port=0") // Random server port
+                .properties("management.endpoints.web.exposure.include=*") // exposure includes all
+                .properties("spring.cloud.bus.trace.enabled=true") // Enable trace
                 .run(args);
     }
 
+    @Autowired
+    private ApplicationEventPublisher publisher;
+
+    @Value("${spring.cloud.bus.id}")
+    private String originService;
+
+    @Value("${server.port}")
+    private int localServerPort;
+
+    @Autowired
+    private ObjectMapper objectMapper;
+
     /**
-     * Publish the {@link UserRemoteApplicationEvent} to all instances of currentService.
+     * Publish the {@link UserRemoteApplicationEvent}
      *
-     * @param publisher      {@link ApplicationEventPublisher}
+     * @param name        the user name
-     * @param currentService Current application Name
+     * @param destination the destination
-     * @return {@link ApplicationRunner} instance
+     * @return If published
      */
-    @Bean
+    @GetMapping("/bus/event/publish/user")
-    public ApplicationRunner publishEventRunner(ApplicationEventPublisher publisher,
+    public boolean publish(@RequestParam String name, @RequestParam(required = false) String destination) {
-                                                @Value("${spring.application.name}") String currentService) {
+        User user = new User();
-        return args -> {
+        user.setId(System.currentTimeMillis());
-            User user = new User();
+        user.setName(name);
-            user.setName("Mercy Ma");
+        publisher.publishEvent(new UserRemoteApplicationEvent(user, originService, destination));
-            for (int i = 1; i < 10; i++) {
+        return true;
-                user.setId(Long.valueOf(i));
-                publisher.publishEvent(new UserRemoteApplicationEvent(user, currentService, currentService + ":**"));
-            }
-        };
     }
 
     /**
@@ -68,6 +84,11 @@ public class RocketMQBusApplication {
      */
     @EventListener
     public void onEvent(UserRemoteApplicationEvent event) {
-        System.out.println("Listener on User : " + event.getUser());
+        System.out.printf("Server [port : %d] listeners on %s\n", localServerPort, event.getUser());
+    }
+
+    @EventListener
+    public void onAckEvent(AckRemoteApplicationEvent event) throws JsonProcessingException {
+        System.out.printf("Server [port : %d] listeners on %s\n", localServerPort, objectMapper.writeValueAsString(event));
     }
 }

spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/resources/application.properties

@@ -1,5 +0,0 @@
-spring.application.name=spring-cloud-bus-rocketmq-example
-
-management.endpoints.web.exposure.include=*
-
-spring.cloud.bus.trace.enabled=true

spring-cloud-alibaba-examples/spring-cloud-bus-rocketmq-example/src/main/resources/bootstrap.properties

@@ -0,0 +1,4 @@
+spring.application.name=spring-cloud-bus-rocketmq-example
+spring.cloud.stream.rocketmq.binder.namesrv-addr=127.0.0.1:9876
+server.port=8080
+spring.cloud.bus.id=${spring.application.name}:${server.port}