Akka Utils

Aggrepoint Akka Utilities

License

License

Categories

Categories

Akka Container Microservices Reactive libraries
GroupId

GroupId

com.aggrepoint.framework
ArtifactId

ArtifactId

ap_akka
Last Version

Last Version

1.0.3
Release Date

Release Date

Type

Type

jar
Description

Description

Akka Utils
Aggrepoint Akka Utilities
Project URL

Project URL

https://github.com/yangjm/ap_akka
Source Code Management

Source Code Management

https://github.com/yangjm/ap_akka

Download ap_akka

How to add to project

<!-- https://jarcasting.com/artifacts/com.aggrepoint.framework/ap_akka/ -->
<dependency>
    <groupId>com.aggrepoint.framework</groupId>
    <artifactId>ap_akka</artifactId>
    <version>1.0.3</version>
</dependency>
// https://jarcasting.com/artifacts/com.aggrepoint.framework/ap_akka/
implementation 'com.aggrepoint.framework:ap_akka:1.0.3'
// https://jarcasting.com/artifacts/com.aggrepoint.framework/ap_akka/
implementation ("com.aggrepoint.framework:ap_akka:1.0.3")
'com.aggrepoint.framework:ap_akka:jar:1.0.3'
<dependency org="com.aggrepoint.framework" name="ap_akka" rev="1.0.3">
  <artifact name="ap_akka" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.aggrepoint.framework', module='ap_akka', version='1.0.3')
)
libraryDependencies += "com.aggrepoint.framework" % "ap_akka" % "1.0.3"
[com.aggrepoint.framework/ap_akka "1.0.3"]

Dependencies

compile (5)

Group / Artifact Type Version
org.springframework : spring-context jar 5.1.3.RELEASE
com.typesafe.akka : akka-actor_2.13 jar 2.5.26
com.typesafe.akka : akka-cluster_2.13 jar 2.5.26
com.typesafe.akka : akka-cluster-tools_2.13 jar 2.5.26
com.aggrepoint.framework : aputils jar 1.0.6

Project Modules

There are no modules declared in this project.

About

Integrates Akka Actor with Spring Framework

Usage

  1. Add annotation @Component and @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) to actor classes
  2. Use @Import to import AkkaConfig.class. Make sure actor classes are in package scanned by Spring
  3. 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);
    }
  1. Inject ActorCreator to classes that need to create Akka actor. Use ActorCreator.create() to create container managed actor instance.
  2. ActorSystem is managed by Spring container, it can be injected by @Autowired

Configuration

  1. Create application.conf in the resources directory in project
  2. 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://[email protected]:5000"];akka.cluster.roles=[app]

Command Line Parameters

  1. Use -port to specify AkkaSystem listen port, for example -port1234
  2. Use -host to specify AkkaSystem binding host, for example -hostcore

Versions

Version
1.0.3
1.0.2
1.0.1
1.0.0