fix bug

liulingling.177216

2024-08-26 349f1cfc5fa77fbc636d542df0d8050fddec48c2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package com.dingzhuo.compute.engine;
 
import akka.actor.ActorSystem;
import com.dingzhuo.compute.engine.utils.ActorUtil;
import com.dingzhuo.compute.engine.utils.SpringAkkaExtension;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * @author fanxinfu
 */
@Configuration
public class ApplicationConfiguration {
 
  private final ApplicationContext applicationContext;
  private final SpringAkkaExtension springAkkaExtension;
 
  public ApplicationConfiguration(
      ApplicationContext applicationContext, SpringAkkaExtension springAkkaExtension) {
    this.applicationContext = applicationContext;
    this.springAkkaExtension = springAkkaExtension;
  }
 
  @Bean
  public ActorSystem actorSystem() {
    ActorSystem system = ActorSystem.create(ActorUtil.ACTOR_SYSTEM, akkaConfiguration());
    springAkkaExtension.initialize(applicationContext);
    system.dispatchers().lookup("computeDispatcher");
    return system;
  }
 
  @Bean
  public Config akkaConfiguration() {
    return ConfigFactory.load("akka");
  }
 
}