| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * @author wuqiong 2022/4/16
|
|---|
| | | * @description
|
|---|
| | | */
|
|---|
| | | public class ApplicationReadyListener implements ApplicationListener<ApplicationReadyEvent>{
|
|---|
| | | public class ApplicationReadyListener implements ApplicationListener<ApplicationReadyEvent> {
|
|---|
| | |
|
|---|
| | | public static final AtomicBoolean START_LISTENER_CONTAINER = new AtomicBoolean(false);
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void onApplicationEvent(ApplicationReadyEvent event) {
|
|---|
| | | // 确保程序启动之后，再放行所有的 canal transponder
|
|---|
| | | if (!START_LISTENER_CONTAINER.get()) START_LISTENER_CONTAINER.set(true);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
