sparrow-spring-boot-starter

Sparrow Spring Book Edition

Support Function:

SendMessage
ConsumerMessage

SendMessage:

Send Message, Method Runs Successfully,Ensure The Normal Operation Of SparrowServer And The Message Must Be Sent Successfully
Method Failed To Run, Message Not Sent.

ConsumerMessage:

Cluster Consumption Messages

Quick Start

<!--Adding dependencies to pom. XML-->
<dependency>
    <artifactId>sparrow-spring-boot-starter</artifactId>
    <groupId>com.github.thierrysquirrel</groupId>
    <version>2.2.1.4-RELEASE</version>
</dependency>

## application.properties
sparrow.sparrow-server-url=127.0.0.1:6060 #If You Need A Cluster 127.0.0.1:6060,127.0.0.1:6061,127.0.0.1:6062

Start Sparrow

@SpringBootApplication
public class SparrowApplication {
   public static void main(String[] args) {
   	SpringApplication.run(DemoApplication.class, args);
   }

}

SendMessage

@RestController
public class SendMessage {

   @GetMapping("/hello")
   @Producer("hello")
   public User sendMessageHello() {
   	User user = new User();
   	user.setId(123);
   	user.setName("hello");
   	return user;
   }

   @GetMapping("/world")
   @Producer("world")
   public User sendMessageWorld() {
   	User user = new User();
   	user.setId(123);
   	user.setName("hello");
   	return user;
   }
}

ConsumerMessage

@SparrowListener
public class ConsumerMessage {

   @ConsumerListener("hello")
   public void hello(User user) {
   	System.out.println(user);
   }

   @ConsumerListener("world")
   public void world(User user) {
   	System.out.println(user);
   }

}