Application Event Subsystem

@Slf4j @SpringBootApplication public class EventsApplication { public static void main(String[] args) { SpringApplication.run(EventsApplication.class, args); } @EventListener void ready(ApplicationReadyEvent are) { System.out.println("application ready event (take 3): " + are.toString()); } @Bean ApplicationListener<ApplicationReadyEvent> applicationReadyEventApplicationListener) { return event → System.out.println("application ready event (take 2): " + event. getTimeTaken ().tostring()); } @Component static class MyListener implements ApplicationListener‹ApplicationReadyEvent> { @Override public void onApplicationEvent(ApplicationReadyEvent event) { System.out.println("application ready event: " + event.getTimeTaken().toString()) ; } } @Bean ApplicationListener<ApplicationReadyEvent> publisher(ApplicationEventPublisher publisher) { return args -> { log.error("xxx-before publish event"); publisher.publishEvent(new MyCustomEvent("xxx-Happy New Year!")); log.error("xxx-after publish event"); }; } } record MyCustomEvent(String messag↓e) { } @Slf4j @Component @EnableAsync public class TestListener { @Async @EventListener public void handle(MyCustomEvent event) { log.error("xxx-TestListener: before sleep"); try { Thread.currentThread().sleep(3_000); } catch (InterruptedException e) { throw new RuntimeException(e); } log.error("xxx-TestListener: after sleep"); log.error("xxx-TestListener: " + event.message()); } }

// @EnableAsync가 없을 때 59 xxx-before publish event 59 xxx-TestListener: before sleep 02 xxx-TestListener: after sleep 02 xxx-TestListener: xxx-Happy New Year! 02 xxx-after publish event // @EnableAsync를 추가했을 때 59 xxx-before publish event 59 xxx-after publish event 59 xxx-TestListener: before sleep 02 xxx-TestListener: after sleep 02 xxx-TestListener: xxx-Happy New Year!

spring.docker.compose.lifecycle-management=start_only

@Async @Transactional(propagation = Propagation.REQUIRES_NEW) @TransactionalEventListener @Documented @Target({ ElementType.METHOD, ElementType.ANNOTATION_TYPE }) @Retention(RetentionPolicy.RUNTIME) @Deprecated(since = "1.1", forRemoval = true) public @interface ApplicationModuleListener {

spring.modulith.republish-outstanding-events-on-restart=true spring.modulith.events.jdbc.schema-initialization.enabled=true

docker compose down docker compose up PGPASSWORD=secret psql -U myuser -h localhost mydatabase

create table event_publication ( id uuid not null primary key, listener_id text not null, event_type text not null, serialized_event text not null, publication_date timestamp with time zone not null, completion_date timestamp with time zone );