actors/org.artofdev.actors.impl.net

Package-level declarations

Types

data class ActorsNetConfig(val implementation: String = ActorNetType.Kafka.name, val kafka: KafkaActorNetConfig? = null, val artemis: ArtemisActorNetConfig? = null)

ArtemisActorNetConfig

data class ArtemisActorNetConfig(val brokerUrl: String, val user: String? = null, val password: String? = null, val queuePrefix: String, val confirmationWindowSize: Int, val producerWindowSize: Int, val consumerWindowSize: Int)

KafkaActorNetConfig

data class KafkaActorNetConfig(val properties: String, val topicPrefix: String, val consumerConfig: KafkaConsumerConfig = KafkaConsumerConfig())

Functions

createActorNet

fun ActorsNetConfig.createActorNet(configPath: String = "actorsNet"): IActorNet

createArtemisActorNet

fun createArtemisActorNet(artemisConfig: ArtemisActorNetConfig): IActorNet

createKafkaActorNet

fun createKafkaActorNet(kafkaConfig: KafkaActorNetConfig): IActorNet