Index (com.mackenziehigh:cascade 2.1 API)

A C D I M N O P R S W
All Classes and Interfaces|All Packages

A

AbstractStage() - Constructor for class com.mackenziehigh.cascade.Cascade.AbstractStage
actor() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Context: Get the enclosing actor.
actor() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Input: Get the actor that this input pertains to.
actor() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Output: Get the actor that this input pertains to.
andThen(Cascade.Stage.Actor.ConsumerErrorHandler) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ConsumerErrorHandler: Compose this script and the given script into a single script.
andThen(Cascade.Stage.Actor.ConsumerErrorHandler) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ContextErrorHandler: Compose this script and the given script into a single script.
andThen(Cascade.Stage.Actor.ContextErrorHandler<I, O>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ContextErrorHandler: Compose this script and the given script into a single script.

C

Cascade - Interface in com.mackenziehigh.cascade: Micro Actor Framework.
Cascade.AbstractStage - Class in com.mackenziehigh.cascade: Partial Implementation of Stage.
Cascade.AbstractStage.DefaultActor<I,O> - Class in com.mackenziehigh.cascade: Default Actor Implementation.
Cascade.ArrayBlockingQueueMailbox - Class in com.mackenziehigh.cascade: A Mailbox implementation based on a ArrayBlockingQueue.
Cascade.ArrayDequeMailbox - Class in com.mackenziehigh.cascade: A Mailbox implementation based on a ArrayDeque.
Cascade.CircularArrayDequeMailbox - Class in com.mackenziehigh.cascade: A Mailbox implementation based on an ArrayDeque, which behaves like a ring-buffer data-structure.
Cascade.ConcurrentLinkedQueueMailbox - Class in com.mackenziehigh.cascade: A Mailbox implementation based on a ConcurrentLinkedQueue.
Cascade.LinkedBlockingQueueMailbox - Class in com.mackenziehigh.cascade: A Mailbox implementation based on a LinkedBlockingQueue.
Cascade.PriorityBlockingQueueMailbox - Class in com.mackenziehigh.cascade: A Mailbox implementation based on a PriorityBlockingQueue.
Cascade.Stage - Interface in com.mackenziehigh.cascade: A group of Actors with a common power supply.
Cascade.Stage.Actor<I,O> - Interface in com.mackenziehigh.cascade: Actor.
Cascade.Stage.Actor.Builder<I,O> - Interface in com.mackenziehigh.cascade: Actor Builder.
Cascade.Stage.Actor.ConsumerErrorHandler - Interface in com.mackenziehigh.cascade: Actor Error Handler.
Cascade.Stage.Actor.ConsumerScript - Interface in com.mackenziehigh.cascade: Actor Behavior.
Cascade.Stage.Actor.Context<I,O> - Interface in com.mackenziehigh.cascade: Script Execution Context.
Cascade.Stage.Actor.ContextErrorHandler<I,O> - Interface in com.mackenziehigh.cascade: Actor Error Handler.
Cascade.Stage.Actor.ContextScript<I,O> - Interface in com.mackenziehigh.cascade: Actor Behavior.
Cascade.Stage.Actor.FunctionScript<I,O> - Interface in com.mackenziehigh.cascade: Actor Behavior.
Cascade.Stage.Actor.Input<T> - Interface in com.mackenziehigh.cascade: Input to an Actor.
Cascade.Stage.Actor.Mailbox - Interface in com.mackenziehigh.cascade: A queue-like (FIFO) data-structure that stores incoming messages.
Cascade.Stage.Actor.Output<T> - Interface in com.mackenziehigh.cascade: Output to an Actor.
close() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage: Asynchronously shutdown this stage, as soon as reasonably possible.
close() - Method in interface com.mackenziehigh.cascade.Cascade.Stage: Asynchronously shutdown this stage, as soon as reasonably possible.
com.mackenziehigh.cascade - package com.mackenziehigh.cascade: Cascade - A Micro Actor Framework.
connect(Cascade.Stage.Actor.Input<T>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Output: Connect this output to the given input of another actor.
connect(Cascade.Stage.Actor.Output<T>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Input: Connect this input to the given output of another actor.
context() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor
context() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor: Get the Context that is passed into ContextScripts.
create() - Static method in class com.mackenziehigh.cascade.Cascade.ConcurrentLinkedQueueMailbox: Create a new mailbox.
create() - Static method in class com.mackenziehigh.cascade.Cascade.LinkedBlockingQueueMailbox: Create a new mailbox.
create() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Construct the actor and add it to the stage.
create(int) - Static method in class com.mackenziehigh.cascade.Cascade.ArrayBlockingQueueMailbox: Create a new mailbox.
create(int) - Static method in class com.mackenziehigh.cascade.Cascade.LinkedBlockingQueueMailbox: Create a new mailbox.
create(int, int) - Static method in class com.mackenziehigh.cascade.Cascade.ArrayDequeMailbox: Create a new mailbox.
create(int, int) - Static method in class com.mackenziehigh.cascade.Cascade.CircularArrayDequeMailbox: Create a new mailbox.
create(int, Comparator) - Static method in class com.mackenziehigh.cascade.Cascade.PriorityBlockingQueueMailbox: Create a new mailbox.

D

disconnect(Cascade.Stage.Actor.Input<T>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Output: Disconnect this output from the given input.
disconnect(Cascade.Stage.Actor.Output<T>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Input: Disconnect this input from the given output.

I

input() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor
input() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor: Get the Input that supplies messages to this actor.
isConnected(Cascade.Stage.Actor.Input<?>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Output: Determine whether this output is connected to the given input.
isConnected(Cascade.Stage.Actor.Output<?>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Input: Determine whether this input is connected to the given output.

M

meta() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor
meta(Object) - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor

N

newActor() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage: Create a builder that can be used to add a new actor to this stage.
newActor() - Method in interface com.mackenziehigh.cascade.Cascade.Stage: Create a builder that can be used to add a new actor to this stage.
newStage() - Static method in interface com.mackenziehigh.cascade.Cascade: Create a new single-threaded stage.
newStage(int) - Static method in interface com.mackenziehigh.cascade.Cascade: Create a new multi-threaded stage.
newStage(int, boolean) - Static method in interface com.mackenziehigh.cascade.Cascade: Create a new multi-threaded stage.
newStage(ExecutorService) - Static method in interface com.mackenziehigh.cascade.Cascade: Create a new stage based on a given ExecutorService.

O

offer(I) - Method in class com.mackenziehigh.cascade.Cascade.ArrayBlockingQueueMailbox: Add a message to the mailbox.
offer(I) - Method in class com.mackenziehigh.cascade.Cascade.ArrayDequeMailbox: Add a message to the mailbox.
offer(I) - Method in class com.mackenziehigh.cascade.Cascade.CircularArrayDequeMailbox: Add a message to the mailbox.
offer(I) - Method in class com.mackenziehigh.cascade.Cascade.ConcurrentLinkedQueueMailbox: Add a message to the mailbox.
offer(I) - Method in class com.mackenziehigh.cascade.Cascade.LinkedBlockingQueueMailbox: Add a message to the mailbox.
offer(I) - Method in class com.mackenziehigh.cascade.Cascade.PriorityBlockingQueueMailbox: Add a message to the mailbox.
offer(I) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Mailbox: Add a message to the mailbox.
offer(T) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Input: Send a message to the actor via this input, silently dropping the message, if this input does not have sufficient capacity to enqueue the message.
offerFrom(O) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Context: Offer a message from the enclosing actor.
offerTo(I) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Context: Offer a message to the enclosing actor.
onClose() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage: This method will be invoked when this stage closes.
onError(Cascade.Stage.Actor.Context<I, O>, I, Throwable) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ContextErrorHandler: This method will be invoked by the enclosing actor in order to handle any unhandled exceptions that are thrown by the script.
onError(Throwable) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ConsumerErrorHandler: This method will be invoked by the enclosing actor in order to handle any unhandled exceptions that are thrown by the script.
onInput(Cascade.Stage.Actor.Context<I, O>, I) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ContextScript: This method will be invoked by the enclosing actor in order to process all incoming messages.
onInput(I) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ConsumerScript: This method will be invoked by the enclosing actor in order to process all incoming messages.
onInput(I) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.FunctionScript: This method will be invoked by the enclosing actor in order to process all incoming messages.
onRunnable(Cascade.AbstractStage.DefaultActor<?, ?>) - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage: This method will be invoked whenever an actor needs executed.
output() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor
output() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor: Get the Output that receives messages from this actor.

P

poll() - Method in class com.mackenziehigh.cascade.Cascade.ArrayBlockingQueueMailbox: Remove a message from the mailbox.
poll() - Method in class com.mackenziehigh.cascade.Cascade.ArrayDequeMailbox: Remove a message from the mailbox.
poll() - Method in class com.mackenziehigh.cascade.Cascade.CircularArrayDequeMailbox: Remove a message from the mailbox.
poll() - Method in class com.mackenziehigh.cascade.Cascade.ConcurrentLinkedQueueMailbox: Remove a message from the mailbox.
poll() - Method in class com.mackenziehigh.cascade.Cascade.LinkedBlockingQueueMailbox: Remove a message from the mailbox.
poll() - Method in class com.mackenziehigh.cascade.Cascade.PriorityBlockingQueueMailbox: Remove a message from the mailbox.
poll() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Mailbox: Remove a message from the mailbox.

R

run() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor

S

send(T) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Input: Send a message to the actor via this input.
sendFrom(O) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Context: Send a message from the enclosing actor.
sendTo(I) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Context: Send a message to the enclosing actor.
silent() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ConsumerErrorHandler: Compose this script within another script, such that any exceptions thrown by this script will be silently ignored.
silent() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.ContextErrorHandler: Compose this script within another script, such that any exceptions thrown by this script will be silently ignored.
stage() - Method in class com.mackenziehigh.cascade.Cascade.AbstractStage.DefaultActor
stage() - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor: Get the Stage that contains this actor.

W

withConsumerErrorHandler(Cascade.Stage.Actor.ConsumerErrorHandler) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Define how the actor responds to unhandled exceptions.
withConsumerScript(Cascade.Stage.Actor.ConsumerScript<X>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Define the normal behavior of the actor.
withContextErrorHandler(Cascade.Stage.Actor.ContextErrorHandler<I, O>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Define how the actor responds to unhandled exceptions.
withContextScript(Cascade.Stage.Actor.ContextScript<X, Y>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Define the normal behavior of the actor.
withFunctionScript(Cascade.Stage.Actor.FunctionScript<X, Y>) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Define the normal behavior of the actor.
withMailbox(Cascade.Stage.Actor.Mailbox) - Method in interface com.mackenziehigh.cascade.Cascade.Stage.Actor.Builder: Cause the actor to use the given mailbox to store incoming messages.

A C D I M N O P R S W
All Classes and Interfaces|All Packages