1   public static void main( String[] args ) {
2     ApplicationContext context = new AnnotationConfigApplicationContext(SimpleSpringConfiguration.class);
3     final Vertx vertx = Vertx.vertx();
4     vertx.deployVerticle(new SpringSimpleVerticle(context));
5     vertx.deployVerticle(new ServerVerticle());
6   }

 1 public class SpringSimpleVerticle extends AbstractVerticle {
 2
 3     public static final String ALL_PRODUCTS_ADDRESS = "example.all.products";
 4
 5
 6     private final ObjectMapper mapper = new ObjectMapper();
 7     private final ProductService service;
 8
 9     public SpringSimpleVerticle(final ApplicationContext context) {
10
11         service = (ProductService) context.getBean("productService");
12
13     }
14
15     private Handler<Message<String>> allProductsHandler(ProductService service, String name) {
16         return ms2g -> vertx.<String>executeBlocking(future -> {
17                     try {
18                         future.complete(mapper.writeValueAsString(service.getAllProducts(ms2g.body())));
19                     } catch (JsonProcessingException e) {
20                         System.out.println("Failed to serialize result");
21                         future.fail(e);
22                     }
23                 },
24                 result -> {
25                     if (result.succeeded()) {
26                         ms2g.reply(result.result());
27                     } else {
28                         ms2g.reply(result.cause().toString());
29                     }
30                 });
31     }
32
33     @Override
34     public void start() throws Exception {
35         super.start();
36
37         System.out.println("<<<<<<<<<<<<<<<<<<<<<<< CONSUMER >>>>>>>>>>>>>>>>>>>>>>>>>");
38         vertx.eventBus().<String>consumer(ALL_PRODUCTS_ADDRESS).handler(allProductsHandler(service, "message"));
39
40     }
41 }

 1 @Service
 2 public class ProductService {
 3
 4     @Autowired
 5     private ProductRepository repo;
 6
 7     public List<Product> getAllProducts(String productId) {
 8         System.out.println("productid : " + productId);
 9         return repo.findAll();
10     }
11
12     public void getProduct(String productId) {
13         System.out.println("productid : " + productId);
14     }
15
16 }