A C D F G I M N O R S T W _
All Classes All Packages

A

activate() - Method in class it.tidalwave.actor.spi.ActorGroupActivator

activatorFor(Class<?>) - Static method in class it.tidalwave.actor.spi.ActorActivator

Creates an instance for the given actor class.

Actor - Annotation Type in it.tidalwave.actor.annotation

An annotation for actors.

ActorActivator - Class in it.tidalwave.actor.spi

This class is used to activate and deactivate an actor.

ActorActivatorStats - Class in it.tidalwave.actor.spi

ActorActivatorStats() - Constructor for class it.tidalwave.actor.spi.ActorActivatorStats

ActorActivatorStatsMBean - Interface in it.tidalwave.actor.spi

ActorGroupActivator - Class in it.tidalwave.actor.spi

ActorGroupActivator() - Constructor for class it.tidalwave.actor.spi.ActorGroupActivator

add(ActorActivator) - Method in class it.tidalwave.actor.spi.ActorGroupActivator

C

changePendingMessageCount(int) - Method in class it.tidalwave.actor.spi.ActorActivatorStats

collaboration - Variable in class it.tidalwave.actor.MessageSupport

Collaboration - Interface in it.tidalwave.actor

Represents a single task that is possibly decomposed in multiple subtasks and provides support for waiting for its completion.

Collaboration.Provider - Interface in it.tidalwave.actor

A provider of a Collaboration.

CollaborationAwareMessageBus - Interface in it.tidalwave.actor.spi

CollaborationCompletedMessage - Class in it.tidalwave.actor

This message notifies that a Collaboration has been completed.

CollaborationStartedMessage - Class in it.tidalwave.actor

This message notifies that a new Collaboration has been started.

D

daemon() - Method in annotation type it.tidalwave.actor.annotation.Message

Doesn't work, don't use it

deactivate() - Method in class it.tidalwave.actor.spi.ActorGroupActivator

dispose() - Method in class it.tidalwave.actor.spi.ActorActivator

Deactivates the managed actor and releases resources.

F

forCollaboration(Collaboration) - Static method in class it.tidalwave.actor.CollaborationCompletedMessage

Creates a new instance for the given Collaboration.

forCollaboration(Collaboration) - Static method in class it.tidalwave.actor.CollaborationStartedMessage

Creates a new instance for the given Collaboration.

G

getCollaboration() - Method in interface it.tidalwave.actor.Collaboration.Provider

Returns the Collaboration.

getCollaboration() - Method in class it.tidalwave.actor.MessageSupport

Returns the Collaboration that this message is part of.

getDecoratedMessage() - Method in interface it.tidalwave.actor.MessageDecorator

Returns the decorated message.

getDeliveringMessagesCount() - Method in interface it.tidalwave.actor.Collaboration

Returns the number of messages related to this Collaboration not yet delivered.

getDuration() - Method in interface it.tidalwave.actor.Collaboration

Return the duration of this Collaboration.

getDuration() - Method in class it.tidalwave.actor.CollaborationCompletedMessage

Returns the time this Collaboration took to complete.

getEndTime() - Method in class it.tidalwave.actor.CollaborationCompletedMessage

Returns the time when the Collaboration has been completed.

getInvocationCount() - Method in interface it.tidalwave.actor.spi.ActorActivatorStatsMBean

getInvocationErrorCount() - Method in interface it.tidalwave.actor.spi.ActorActivatorStatsMBean

getOriginatingMessage() - Method in interface it.tidalwave.actor.Collaboration

Returns the message that originated this Collaboration.

getPendingMessageCount() - Method in interface it.tidalwave.actor.spi.ActorActivatorStatsMBean

getPendingMessagesCount() - Method in interface it.tidalwave.actor.Collaboration

Returns the number of messages related to this Collaboration not yet consumed.

getPoolSize() - Method in interface it.tidalwave.actor.spi.ActorActivatorStatsMBean

getRunningThreadsCount() - Method in interface it.tidalwave.actor.Collaboration

Returns the number of running threads assigned to this Collaboration.

getStartTime() - Method in interface it.tidalwave.actor.Collaboration

Return the time when this Collaboration has been created.

getStartTime() - Method in class it.tidalwave.actor.CollaborationCompletedMessage

Returns the time when the Collaboration has been started.

getStartTime() - Method in class it.tidalwave.actor.CollaborationStartedMessage

Returns the time when the Collaboration has been started.

getSuccesfulInvocationCount() - Method in interface it.tidalwave.actor.spi.ActorActivatorStatsMBean

I

incrementInvocationCount() - Method in class it.tidalwave.actor.spi.ActorActivatorStats

incrementInvocationErrorCount() - Method in class it.tidalwave.actor.spi.ActorActivatorStats

incrementSuccessfulInvocationCount() - Method in class it.tidalwave.actor.spi.ActorActivatorStats

initialize() - Method in class it.tidalwave.actor.spi.ActorActivator

Activates the managed actor.

initialPriority() - Method in annotation type it.tidalwave.actor.annotation.Actor

The initial priority for the threads that will execute the code of the annotated actor.

isCompleted() - Method in interface it.tidalwave.actor.Collaboration

Returns true if the Collaboration has been completed.

isSuspended() - Method in interface it.tidalwave.actor.Collaboration

Returns true when the current Collaboration is suspended.

it.tidalwave.actor - package it.tidalwave.actor

it.tidalwave.actor.annotation - package it.tidalwave.actor.annotation

it.tidalwave.actor.spi - package it.tidalwave.actor.spi

M

maybeAs(Class<? extends T>) - Method in class it.tidalwave.actor.MessageSupport

Message - Annotation Type in it.tidalwave.actor.annotation

MessageDecorator - Interface in it.tidalwave.actor

This role should be injected into a message to decorated it at the moment of sending.

MessageDecorator.Same<T extends MessageSupport> - Class in it.tidalwave.actor

A default implementation of MessageDecorator which returns the same message.

MessageSupport - Class in it.tidalwave.actor

A support class for implementing messages.

MessageSupport() - Constructor for class it.tidalwave.actor.MessageSupport

MessageSupport(Collaboration) - Constructor for class it.tidalwave.actor.MessageSupport

N

NULL_COLLABORATION - Static variable in interface it.tidalwave.actor.Collaboration

O

OriginatedBy - Annotation Type in it.tidalwave.actor.annotation

outOfBand() - Method in annotation type it.tidalwave.actor.annotation.Message

Out of band messages are processed with priority, i.e.

R

resume(Object, Runnable) - Method in interface it.tidalwave.actor.Collaboration

Resumes a suspended Collaboration.

resumeAndDie(Object) - Method in interface it.tidalwave.actor.Collaboration

Resumes a suspended Collaboration and lets it terminate without any further operation.

S

Same() - Constructor for class it.tidalwave.actor.MessageDecorator.Same

send() - Method in class it.tidalwave.actor.MessageSupport

Sends this message, eventually performing a replacement (see MessageDecorator for further info).

sendDirectly() - Method in class it.tidalwave.actor.MessageSupport

Sends this message directly, not performing any replacement (see MessageDecorator for further info).

sendLater(int, TimeUnit) - Method in class it.tidalwave.actor.MessageSupport

Sends this message after a delay, eventually performing a replacement (see MessageDecorator for further info).

suspend() - Method in interface it.tidalwave.actor.Collaboration

Sometimes a Collaboration must coordinate with the external world, waiting for an external asynchronous event that cannot be modeled with agents.

T

threadSafe() - Method in annotation type it.tidalwave.actor.annotation.Actor

W

waitForCompletion() - Method in interface it.tidalwave.actor.Collaboration

Waits for the completion of this Collaboration.

withPoolSize(int) - Method in class it.tidalwave.actor.spi.ActorActivator

Specifies the pool size for this activator.

_

_MessageDecorator_ - Static variable in interface it.tidalwave.actor.MessageDecorator

A C D F G I M N O R S T W _
All Classes All Packages