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