JarCastingAbout
Integrates Akka Actor with Spring Framework
Usage
- Add annotation @Component and @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) to actor classes
- Use @Import to import AkkaConfig.class. Make sure actor classes are in package scanned by Spring
- In the main() function of the application, before calling SpringApplication.run(), call AkkaConfig.processArgs() to process command line arguments
public static void main(String[] args) {
AkkaConfig.processArgs(args);
SpringApplication.run(SchedulerApplication.class, args);
}
- Inject ActorCreator to classes that need to create Akka actor. Use ActorCreator.create() to create container managed actor instance.
- ActorSystem is managed by Spring container, it can be injected by @Autowired
Configuration
- Create application.conf in the resources directory in project
- Configure akka.system.name and akka.conf in project's application.properties or application.yml. For example:
akka.system.name=akkaapp
akka.conf=akka.remote.netty.tcp.port=5000;akka.cluster.seed-nodes=["akka.tcp://akkaapp@127.0.0.1:5000"];akka.cluster.roles=[app]
Command Line Parameters
- Use -port to specify AkkaSystem listen port, for example -port1234
- Use -host to specify AkkaSystem binding host, for example -hostcore