RocketMQ pollable example.

spring-cloud-alibaba-examples/rocketmq-example/rocketmq-pollable-consume-example/src/main/java/com/alibaba/cloud/examples/pollable/RocketMQPollableConsumeApplication.java

@@ -66,13 +66,13 @@ public class RocketMQPollableConsumeApplication {
 	}
 
 	@Bean
-	public ApplicationRunner pollable(PollableMessageSource destIn) {
+	public ApplicationRunner pollableRunner(PollableMessageSource destIn) {
 		return args -> {
 			while (true) {
 				try {
 					if (!destIn.poll((m) -> {
 						SimpleMsg newPayload = (SimpleMsg)m.getPayload();
-						System.out.println(newPayload.toString());
+						System.out.println(newPayload.getMsg());
 					}, new ParameterizedTypeReference<SimpleMsg>() {})) {
 						Thread.sleep(1000);
 					}

spring-cloud-alibaba-examples/rocketmq-example/rocketmq-pollable-consume-example/src/main/resources/application.yml

@@ -2,7 +2,7 @@ server:
   port: 28089
 spring:
   application:
-    name: rocketmq-delay-consume-example
+    name: rocketmq-pollable-consume-example
   cloud:
     stream:
       pollable-source: pollable