<dependency>
    <groupId>.me.jollyfly</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>1.2.1.RELEASE</version>
</dependency>

@SpringBootApplication
@EnableRocket
public class MyApp {

    public static void main(String[] args) {
        SpringApplication.run(MyApp.class,args);
    }
}

rocketmq.name-srv-addr=localhost:9876

@RocketListeners(topic = "MY_TOPIC")
public class MyListener {

    @RocketMQListener(messageClass = String.class,tag = "TAG_1")
    public void method1(String message){
        System.out.println(message);
    }

    @RocketMQListener(messageClass = Object.class,tag = "TAG_2")
    public void method2(Object message){
        System.out.println(message.toString());
    }

}