Package org.apache.pekko.actor.typed.internal

Interface ExtensionsImpl

All Superinterfaces:

Extensions

public interface ExtensionsImpl
extends Extensions

INTERNAL API

Actor system extensions registry

Method Summary

Modifier and Type	Method	Description
<T extends Extension> T	createExtensionInstance(ExtensionId<T> ext)
<T extends Extension> T	extension(ExtensionId<T> ext)	Returns the payload that is associated with the provided extension throws an IllegalStateException if it is not registered.
<T extends Extension> T	findExtension(ExtensionId<T> ext)	Returns any extension registered to the specified Extension or returns null if not registered
boolean	hasExtension(ExtensionId<? extends Extension> ext)	Returns whether the specified extension is already registered, this method can potentially block, waiting for the initialization of the payload, if is in the process of registration from another Thread of execution
scala.util.Try<ExtensionId<Extension>>	idFromJavaSingletonAccessor(java.lang.String extensionIdFQCN)
void	loadExtensions()	Hook for ActorSystem to load extensions on startup
void	loadExtensionsFor(java.lang.String key, boolean throwOnLoadFail)
<T extends Extension> T	registerExtension(ExtensionId<T> ext)	Registers the provided extension and creates its payload, if this extension isn't already registered This method has putIfAbsent-semantics, this method can potentially block, waiting for the initialization of the payload, if is in the process of registration from another Thread of execution

Method Detail

createExtensionInstance

<T extends Extension> T createExtensionInstance(ExtensionId<T> ext)

extension

<T extends Extension> T extension(ExtensionId<T> ext)

Description copied from interface: Extensions

Returns the payload that is associated with the provided extension throws an IllegalStateException if it is not registered. This method can potentially block, waiting for the initialization of the payload, if is in the process of registration from another Thread of execution

Specified by:

extension in interface Extensions

findExtension

<T extends Extension> T findExtension(ExtensionId<T> ext)

Returns any extension registered to the specified Extension or returns null if not registered

hasExtension

boolean hasExtension(ExtensionId<? extends Extension> ext)

Description copied from interface: Extensions

Returns whether the specified extension is already registered, this method can potentially block, waiting for the initialization of the payload, if is in the process of registration from another Thread of execution

Specified by:

hasExtension in interface Extensions

idFromJavaSingletonAccessor

scala.util.Try<ExtensionId<Extension>> idFromJavaSingletonAccessor(java.lang.String extensionIdFQCN)

loadExtensions

void loadExtensions()

Hook for ActorSystem to load extensions on startup

loadExtensionsFor

void loadExtensionsFor(java.lang.String key,
                       boolean throwOnLoadFail)

registerExtension

<T extends Extension> T registerExtension(ExtensionId<T> ext)

Description copied from interface: Extensions

Registers the provided extension and creates its payload, if this extension isn't already registered This method has putIfAbsent-semantics, this method can potentially block, waiting for the initialization of the payload, if is in the process of registration from another Thread of execution

Specified by:

registerExtension in interface Extensions