actors/org.artofdev.actors.impl.net.artemis/ArtemisActorNet

ArtemisActorNet

class ArtemisActorNet(queuePrefix: String, malformedMessagesDir: String, jacksonMapper: ObjectMapper, sessionFactory: ClientSessionFactory, sessionConfig: ArtemisSessionConfig) : IActorNet

Constructors

ArtemisActorNet

constructor(queuePrefix: String, malformedMessagesDir: String, jacksonMapper: ObjectMapper, sessionFactory: ClientSessionFactory, sessionConfig: ArtemisSessionConfig)

Functions

open override fun close()

connectActor

open override fun connectActor(address: ActorIdent, group: ActorGroup?, subscriptions: List<ActorIdent>, extraHeaders: MessageExtraHeaders): ActorConnection

createActorGroup

open override fun createActorGroup(address: ActorIdent): ActorGroup

deliverMessage

open override fun deliverMessage(message: MessageEnvelope)