@Test @SneakyThrows public void process() { Thread.sleep(1 * 1000); Executors.newSingleThreadScheduledExecutor() .scheduleAtFixedRate( this::send, 0, 3, TimeUnit.SECONDS); Thread.sleep(12 * 1000); }
@RabbitHandler public void process(ExampleEvent msg) { log.info("param:{msg = [" + msg + "]} info:"); }
MultipartConsumer { @RabbitHandler public void process(ExampleEvent msg) { log.info("param:{msg = [" + msg + "]} info:"); } }
MultipartConsumer { @RabbitHandler public void process(ExampleEvent msg) { log.info("param:{msg = [" + msg + "]} info:"); }  }
MultipartConsumer { @RabbitHandler public void process(ExampleEvent msg) { log.info("param:{msg = [" + msg + "]} info:"); }  @RabbitHandler void process(ExampleEvent msg); @RabbitHandler void processMessage2(ExampleEvent2 msg); @RabbitHandler void processMessage3(ExampleEvent3 msg); }
MultipartConsumer { @RabbitHandler public void process(ExampleEvent msg) { log.info("param:{msg = [" + msg + "]} info:"); }  @RabbitHandler void process(ExampleEvent msg); @RabbitHandler void processMessage2(ExampleEvent2 msg); @RabbitHandler void processMessage3(ExampleEvent3 msg);  }