Index
All Classes and Interfaces|All Packages|Serialized Form
A
- activate() - Static method in class com.github.devmix.process.acto.messages.Idle
-
Returns a singleton instance of the
Idle.Activatemessage, indicating that the Active Object should transition from idle to active state. - Activate() - Constructor for class com.github.devmix.process.acto.messages.Idle.Activate
-
Default constructor for creating an
Idle.Activatemessage instance. - ACTIVATED - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state of an Active Object indicating that it is ready to handle messages and perform its operations.
- ACTIVATING - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state where the Active Object is in the process of transitioning from the ACTIVATED state to DEACTIVATED.
- ActiveObject<T> - Interface in com.github.devmix.process.acto
-
Represents an active object that encapsulates its state and processes requests asynchronously.
- ActiveObjectContext<T> - Interface in com.github.devmix.process.acto
-
Represents the context of an active object, providing methods to manage dependencies, lifecycle, and message handling.
- ActiveObjectDependency - Interface in com.github.devmix.process.acto
-
Represents a dependency between active objects.
- ActiveObjectDependency.Type - Enum Class in com.github.devmix.process.acto
-
Enumerates the types of relationships that can exist between active objects.
- ActiveObjectFactory<T,
I, - Interface in com.github.devmix.process.actoO> -
Factory interface for creating ActiveObject instances.
- ActiveObjectLifecycle<T> - Interface in com.github.devmix.process.acto
-
This interface represents the lifecycle of an Active Object, which encapsulates asynchronous method invocation behavior.
- ActiveObjectsDispatcher - Interface in com.github.devmix.process.acto
-
The ActiveObjectsDispatcher interface defines methods for managing active objects and their lifecycle in a system.
- ActiveObjectStatus - Enum Class in com.github.devmix.process.acto
-
Represents the possible states of an Active Object in its lifecycle.
- addDependsOn(Object, boolean) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Adds a dependency on another active object with specified optional flag.
- AttributeGetter<T,
R> - Interface in com.github.devmix.process.acto.messages -
Represents a function that extracts an attribute from a target object.
- AttributeSetter<T,
V> - Interface in com.github.devmix.process.acto.messages -
Functional interface representing an operation that sets a value to a target object.
- awaitEmptyQueue(long, TimeUnit) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Waits until the message queue of this active object becomes empty.
C
- com.github.devmix.process.acto - package com.github.devmix.process.acto
- com.github.devmix.process.acto.exceptions - package com.github.devmix.process.acto.exceptions
- com.github.devmix.process.acto.listeners - package com.github.devmix.process.acto.listeners
- com.github.devmix.process.acto.messages - package com.github.devmix.process.acto.messages
- create(ActiveObjectFactory<T, I, O>, I, O) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Creates an instance of an active object using the provided factory, id, and options.
- create(I, O) - Method in interface com.github.devmix.process.acto.ActiveObjectFactory
-
Creates an instance of an ActiveObject.
- create(Class<T>, I, O) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Creates an instance of an active object using the provided class type, id, and options.
- CREATED - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The initial state of an Active Object, indicating that it has been created but not yet started.
- CREATING - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state where the Active Object is in the process of starting up and initializing.
D
- deactivate() - Static method in class com.github.devmix.process.acto.messages.Idle
-
Creates and returns an instance of the
Idle.Deactivatemessage, indicating that the Active Object should transition from active to idle state without forcing the transition. - Deactivate() - Constructor for class com.github.devmix.process.acto.messages.Idle.Deactivate
- DEACTIVATED - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state of an Active Object indicating that it has ceased handling messages and is not performing its operations.
- deactivateNow() - Static method in class com.github.devmix.process.acto.messages.Idle
-
Returns a singleton instance of the
Idle.Deactivatemessage, indicating that the Active Object should transition from active to idle state and forcing the transition immediately. - DEACTIVATING - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state where the Active Object is in the process of transitioning from the ACTIVATED state to DEACTIVATED.
- DependencyException - Exception Class in com.github.devmix.process.acto.exceptions
-
Exception thrown to indicate a problem with dependency resolution during lifecycle operations.
- DependencyException(String) - Constructor for exception class com.github.devmix.process.acto.exceptions.DependencyException
-
Constructs a new
DependencyExceptionwith the specified detail message. - DependencyException(String, Throwable) - Constructor for exception class com.github.devmix.process.acto.exceptions.DependencyException
-
Constructs a new
DependencyExceptionwith the specified detail message and cause. - DEPENDS_ON - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectDependency.Type
-
Indicates a dependency where one object depends on another.
- destroy(Object, boolean) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Destroys an active object with the specified ID.
- DESTROYED - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The final terminal state of an Active Object, indicating that it has been fully destroyed and no longer exists.
- DESTROYING - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state where the Active Object is in the process of transitioning from the STOPPED state to the DESTROYED state.
- DispatchingException - Exception Class in com.github.devmix.process.acto.exceptions
-
Represents an exception that occurs during the dispatching process of an active object.
- DispatchingException(String) - Constructor for exception class com.github.devmix.process.acto.exceptions.DispatchingException
-
Constructs a new
DispatchingExceptionwith the specified detail message. - DispatchingException(String, Throwable) - Constructor for exception class com.github.devmix.process.acto.exceptions.DispatchingException
-
Constructs a new
DispatchingExceptionwith the specified detail message and cause. - downstream(ActiveObject<?>, Start, boolean) - Static method in class com.github.devmix.process.acto.messages.Start
-
Creates a new Start instance based on an existing one, with the provided source and optionality flag.
E
- ensureObject() - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Ensures that the object is resolved and returns it.
F
- findById(Object) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Finds an active object by its ID.
- findDependsOn(Object) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Finds a dependency on another active object by its identifier.
- findRequiredFor(Object) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Finds a required dependency for another active object by its identifier.
- force() - Static method in class com.github.devmix.process.acto.messages.Stop
-
Creates a new stop message with the force flag set to true.
- forEachDependency(Consumer<ActiveObjectDependency>, ActiveObjectDependency.Type) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Applies a function to each dependency, optionally filtering by type.
G
- get(AttributeGetter<T, R>) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously retrieves an attribute from the encapsulated instance using the provided
AttributeGetter. - get(T) - Method in interface com.github.devmix.process.acto.messages.AttributeGetter
-
Extracts an attribute from the given target.
- getById(Object) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Finds an active object by its ID.
- getDependsOn(Object) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Retrieves a dependency on another active object by its identifier.
- getId() - Method in interface com.github.devmix.process.acto.ActiveObject
-
Returns a unique identifier for this active object.
- getId() - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Returns a unique identifier for this active object.
- getIdleTimeout() - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Returns the current idle timeout for this active object.
- getIdleTimeout() - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Returns the idle timeout for an active object in nanoseconds.
- getInstance() - Method in interface com.github.devmix.process.acto.ActiveObject
-
Returns the encapsulated instance managed by this active object.
- getInstance() - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Returns the current instance held by this active object.
- getLastError() - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Returns the last error message that occurred during the resolution process, or an empty string if no errors have occurred.
- getObject() - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Returns the object if it has already been resolved, or null otherwise.
- getOptions() - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Returns the options associated with this active object context.
- getStatus() - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Returns the current status of this active object.
- getType() - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Returns the type of dependency relationship.
- getWaitMessagesTimeout() - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Returns the current wait messages timeout for this active object.
- getWaitMessagesTimeout() - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Returns the wait messages timeout for an active object in nanoseconds.
I
- Idle - Class in com.github.devmix.process.acto.messages
-
Represents an Active Object message for controlling idle state transitions.
- Idle.Activate - Class in com.github.devmix.process.acto.messages
-
Represents an Active Object message indicating a request to activate, transitioning from idle to active state.
- Idle.Deactivate - Class in com.github.devmix.process.acto.messages
-
Represents an Active Object message indicating a request to deactivate, transitioning from active to idle state.
- ifResolved(Consumer<ActiveObject<?>>) - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Executes the provided action if and when the object is resolved.
- invoke(Invoke<T>) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously invokes a method on the encapsulated instance using the provided
Invoke. - Invoke<T> - Interface in com.github.devmix.process.acto.messages
-
Functional interface representing an operation that accepts a single input argument and performs some action.
- InvokeAndGet<T,
R> - Interface in com.github.devmix.process.acto.messages -
Functional interface representing an operation that takes a single argument and returns a result, allowing for checked exceptions to be thrown during its execution.
- invokeAnForget(Invoke<T>) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously invokes a method on the encapsulated instance using the provided
Invoke, without waiting for the operation to complete. - isOptional() - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Indicates whether this dependency is optional.
- isResolved() - Method in interface com.github.devmix.process.acto.ActiveObjectDependency
-
Checks whether the object has been resolved and is available for use.
- isVisited(Object) - Method in class com.github.devmix.process.acto.messages.Start
-
Checks if an object ID has already been visited during processing.
- isVisited(Object) - Method in class com.github.devmix.process.acto.messages.Stop
-
Checks whether the given object ID has been visited during the stopping process.
N
- nonBlocked() - Static method in class com.github.devmix.process.acto.messages.Stop
-
Creates a new stop message with the force flag set to false.
O
- ObjectStopException - Exception Class in com.github.devmix.process.acto.exceptions
-
An exception indicating that an object failed to stop due to a blocking condition or external factor.
- ObjectStopException(String, Object) - Constructor for exception class com.github.devmix.process.acto.exceptions.ObjectStopException
-
Constructs an instance of
ObjectStopExceptionwith the specified detail message and the ID of the object that blocked the stop. - OnCreateListener<T> - Interface in com.github.devmix.process.acto.listeners
-
Interface for listeners that are interested in object creation events within an Active Object context.
- OnDestroyListener<T> - Interface in com.github.devmix.process.acto.listeners
-
This functional interface defines a contract for listeners that need to be notified when an object is destroyed.
- OnIdleListener<T> - Interface in com.github.devmix.process.acto.listeners
-
Represents a listener for idle events in an active object context.
- OnMessageListener<T> - Interface in com.github.devmix.process.acto.listeners
-
Functional interface that represents a listener for messages.
- onObjectActivate(Idle.Activate, ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnIdleListener
-
Called when an object is activated due to an idle event.
- onObjectCreate(ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnCreateListener
-
Method to be called when a new object is created within an Active Object context.
- onObjectDeactivate(Idle.Deactivate, ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnIdleListener
-
Called when an object is deactivated due to an idle event.
- onObjectDestroy(ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnDestroyListener
-
This method is called when an object is destroyed.
- onObjectMessage(Object, ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnMessageListener
-
This method is called when an object message is received.
- onObjectStart(Start, ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnStartListener
-
Called when an object starts.
- onObjectStop(Stop, ActiveObjectContext<T>) - Method in interface com.github.devmix.process.acto.listeners.OnStopListener
-
Called when the active object is about to be stopped.
- OnStartListener<T> - Interface in com.github.devmix.process.acto.listeners
-
Represents a listener that is called when an object starts.
- OnStopListener<T> - Interface in com.github.devmix.process.acto.listeners
-
Interface for a listener that handles stop events in an active object context.
R
- redirectRequest(Object, Object) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Redirects a request to another active object and returns a future for its response.
- redirectRequestAndForget(Object, Object) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Redirects a request to another active object and forgets it (does not expect response).
- registerFactory(Class<T>, ActiveObjectFactory<T, I, O>) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Registers a factory with this dispatcher, which will be used to create instances of the specified class type.
- registerLifecycle(Class<T>, ActiveObjectLifecycle<T>) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Registers a lifecycle callback for the specified class type.
- RegistryException - Exception Class in com.github.devmix.process.acto.exceptions
-
Custom exception class representing a registry-related error in the Active Object pattern implementation.
- RegistryException(String) - Constructor for exception class com.github.devmix.process.acto.exceptions.RegistryException
-
Constructs a new
RegistryExceptionwith the specified detail message. - RegistryException(String, Throwable) - Constructor for exception class com.github.devmix.process.acto.exceptions.RegistryException
-
Constructs a new
RegistryExceptionwith the specified detail message and cause. - request(Object) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously processes a request message, returning the result.
- requestAndForget(Object) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously processes a request message without waiting for the result.
- REQUIRED_FOR - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectDependency.Type
-
Indicates a dependency where one object is required for another.
- run(T) - Method in interface com.github.devmix.process.acto.messages.Invoke
-
Performs this operation on the given argument.
- run(T) - Method in interface com.github.devmix.process.acto.messages.InvokeAndGet
-
Executes the operation using the specified argument.
S
- set(AttributeSetter<T, V>, V) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously sets an attribute in the encapsulated instance using the provided
AttributeSetter. - set(T, V) - Method in interface com.github.devmix.process.acto.messages.AttributeSetter
-
Sets the specified value to the given target object.
- setAndForget(AttributeSetter<T, V>, V) - Method in interface com.github.devmix.process.acto.ActiveObject
-
Asynchronously sets an attribute in the encapsulated instance using the provided
AttributeSetter, without waiting for the operation to complete. - setIdleTimeout(long) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Sets a new idle timeout for this active object.
- setInstance(T) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Sets a new instance for this active object.
- setWaitMessagesTimeout(long) - Method in interface com.github.devmix.process.acto.ActiveObjectContext
-
Sets a new wait messages timeout for this active object.
- shutdown(boolean) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Shuts down all active objects managed by this dispatcher.
- standard() - Static method in class com.github.devmix.process.acto.messages.Start
-
Creates a standard Start instance without any parameters.
- Start - Class in com.github.devmix.process.acto.messages
-
Represents a message to start processing with an Active Object.
- STARTED - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state of an Active Object after it has completed its startup sequence.
- starting(ActiveObject<?>) - Method in class com.github.devmix.process.acto.messages.Start
-
Adds an active object to the chain and records its ID as visited.
- STARTING - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state where the Active Object is transitioning from the CREATED or STOPPED states to the STARTED state.
- Stop - Class in com.github.devmix.process.acto.messages
-
Represents a message to stop an Active Object or a chain of Active Objects.
- STOPPED - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state of an Active Object indicating that it is shutting down and preparing for destruction.
- stopping(ActiveObject<?>) - Method in class com.github.devmix.process.acto.messages.Stop
-
Records an Active Object as part of the stopping process.
- STOPPING - Enum constant in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
The state where the Active Object is in the process of transitioning from the ACTIVATED or DEACTIVATED states to the STOPPED state.
U
- unregisterFactory(Class<?>) - Method in interface com.github.devmix.process.acto.ActiveObjectsDispatcher
-
Unregisters a previously registered factory for the specified class type.
- upstream(ActiveObject<?>, Stop) - Static method in class com.github.devmix.process.acto.messages.Stop
-
Creates a new stop message that is an upstream continuation of the given stop message.
V
- valueOf(String) - Static method in enum class com.github.devmix.process.acto.ActiveObjectDependency.Type
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class com.github.devmix.process.acto.ActiveObjectDependency.Type
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class com.github.devmix.process.acto.ActiveObjectStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
All Classes and Interfaces|All Packages|Serialized Form