actors/org.artofdev.actors

Package-level declarations

Types

interface Actor

abstract class ActorBase : Closeable, Actor

ActorConnection

interface ActorConnection : Closeable

data class ActorGroup(val address: ActorIdent)

Actors in a group receive messages as competing workers. So any particular message will be received only by one actor.

data class ActorIdent(val ident: String)

class DoNoMoreThen(var period: Duration, block: () -> Unit)

interface IActorNet : Closeable

object JacksonUtils

interface Message

MessageEnvelope

data class MessageEnvelope(val header: MessageHeader, val message: Message)

MessageExtraHeaders

typealias MessageExtraHeaders = Map<String, List<String>>

data class MessageHeader(val id: MessageId, val addressFrom: ActorIdent, val addressTo: ActorIdent?, val time: Instant, val extraHeaders: MessageExtraHeaders = emptyMap())

typealias MessageId = String

data class PingMessage(val session: Int, val pingId: Int) : Message

data class PongMessage(val session: Int, val pingId: Int) : Message

SimpleThreadObject

abstract class SimpleThreadObject

class ThreadExecutor<R>(autoStart: Boolean = false, block: () -> R)

Functions

createPropertiesFromString

fun createPropertiesFromString(str: String): Properties

makeActorAddressFromHostname

fun makeActorAddressFromHostname(): ActorIdent