A B C D E F G I K L N O P R S T U W

A

ADD_NODE - Static variable in class org.codehaus.activecluster.ClusterEvent

A node has joined the cluster

ActiveMQClusterFactory - class org.codehaus.activecluster.impl.ActiveMQClusterFactory.

An implementation of ClusterFactory using ActiveMQ

ActiveMQClusterFactory() - Constructor for class org.codehaus.activecluster.impl.ActiveMQClusterFactory

ActiveMQClusterFactory(String) - Constructor for class org.codehaus.activecluster.impl.ActiveMQClusterFactory

ActiveMQClusterFactory(ActiveMQConnectionFactory) - Constructor for class org.codehaus.activecluster.impl.ActiveMQClusterFactory

ActiveMQClusterFactory(boolean, int, String, long) - Constructor for class org.codehaus.activecluster.impl.ActiveMQClusterFactory

ActiveMQClusterFactory(ActiveMQConnectionFactory, boolean, int, String, long) - Constructor for class org.codehaus.activecluster.impl.ActiveMQClusterFactory

addClusterListener(ClusterListener) - Method in interface org.codehaus.activecluster.Cluster

Adds a new listener to cluster events

addClusterListener(ClusterListener) - Method in class org.codehaus.activecluster.impl.DefaultCluster

addClusterListener(ClusterListener) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

B

BullyElectionStrategy - class org.codehaus.activecluster.election.impl.BullyElectionStrategy.

BullyElectionStrategy Use a simple bully algorithm to elect a coordinator.

BullyElectionStrategy() - Constructor for class org.codehaus.activecluster.election.impl.BullyElectionStrategy

C

Cluster - interface org.codehaus.activecluster.Cluster.

Represents a logical connection to a cluster.

ClusterEvent - class org.codehaus.activecluster.ClusterEvent.

A cluster event

ClusterEvent() - Constructor for class org.codehaus.activecluster.ClusterEvent

empty constructor

ClusterEvent(Cluster, Node, int) - Constructor for class org.codehaus.activecluster.ClusterEvent

ClusterException - exception org.codehaus.activecluster.ClusterException.

Represents a Cluster related exception

ClusterException() - Constructor for class org.codehaus.activecluster.ClusterException

ClusterFactory - interface org.codehaus.activecluster.ClusterFactory.

A Factory of Cluster instances

ClusterListener - interface org.codehaus.activecluster.ClusterListener.

Listener to events occuring on the cluster

checkForTimeouts() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

coordinator - Variable in class org.codehaus.activecluster.impl.NodeImpl

coordinatorChanged(Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

createBytesMessage() - Method in interface org.codehaus.activecluster.Cluster

Creates a new bytes message

createBytesMessage() - Method in class org.codehaus.activecluster.impl.DefaultCluster

createCluster(Topic) - Method in interface org.codehaus.activecluster.ClusterFactory

Creates a new cluster connection using the given group

createCluster(String) - Method in interface org.codehaus.activecluster.ClusterFactory

Creates a new cluster connection using the given topic name

createCluster(Topic) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

createCluster(String) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

createCluster(Connection, Session, Topic) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

createConsumer(Destination) - Method in interface org.codehaus.activecluster.Cluster

Creates a consumer of all the messags sent to the given destination, including messages sent via the send() messages

createConsumer(Destination, String) - Method in interface org.codehaus.activecluster.Cluster

Creates a consumer of all message sent to the given destination, including messages sent via the send() message with an optional SQL 92 based selector to filter messages

createConsumer(Destination, String, boolean) - Method in interface org.codehaus.activecluster.Cluster

Creates a consumer of all message sent to the given destination, including messages sent via the send() message with an optional SQL 92 based selector to filter messages along with optionally ignoring local traffic - messages sent via the send() method on this object.

createConsumer(Destination) - Method in class org.codehaus.activecluster.impl.DefaultCluster

createConsumer(Destination, String) - Method in class org.codehaus.activecluster.impl.DefaultCluster

createConsumer(Destination, String, boolean) - Method in class org.codehaus.activecluster.impl.DefaultCluster

createMapMessage() - Method in interface org.codehaus.activecluster.Cluster

Creates a new MapMessage

createMapMessage() - Method in class org.codehaus.activecluster.impl.DefaultCluster

createMessage() - Method in interface org.codehaus.activecluster.Cluster

Creates a new message without a body

createMessage() - Method in class org.codehaus.activecluster.impl.DefaultCluster

createObjectMessage() - Method in interface org.codehaus.activecluster.Cluster

Creates a new ObjectMessage

createObjectMessage(Serializable) - Method in interface org.codehaus.activecluster.Cluster

Creates a new ObjectMessage

createObjectMessage() - Method in class org.codehaus.activecluster.impl.DefaultCluster

createObjectMessage(Serializable) - Method in class org.codehaus.activecluster.impl.DefaultCluster

createProducer(Session, Topic) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

createSession(Connection) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

createStreamMessage() - Method in interface org.codehaus.activecluster.Cluster

Creates a new StreamMessage

createStreamMessage() - Method in class org.codehaus.activecluster.impl.DefaultCluster

createTextMessage() - Method in interface org.codehaus.activecluster.Cluster

Creates a new TextMessage

createTextMessage(String) - Method in interface org.codehaus.activecluster.Cluster

Creates a new TextMessage

createTextMessage() - Method in class org.codehaus.activecluster.impl.DefaultCluster

createTextMessage(String) - Method in class org.codehaus.activecluster.impl.DefaultCluster

createTimerTask() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

D

DEFAULT_CLUSTER_URL - Static variable in class org.codehaus.activecluster.impl.ActiveMQClusterFactory

DefaultCluster - class org.codehaus.activecluster.impl.DefaultCluster.

A default implementation of ActiveCluster which uses standard JMS operations

DefaultCluster(LocalNode, Topic, Topic, Connection, Session, MessageProducer, Timer, long) - Constructor for class org.codehaus.activecluster.impl.DefaultCluster

DefaultClusterFactory - class org.codehaus.activecluster.impl.DefaultClusterFactory.

A Factory of DefaultCluster instances

DefaultClusterFactory(ConnectionFactory, boolean, int, String, long) - Constructor for class org.codehaus.activecluster.impl.DefaultClusterFactory

DefaultClusterFactory(ConnectionFactory) - Constructor for class org.codehaus.activecluster.impl.DefaultClusterFactory

doElection(Cluster) - Method in interface org.codehaus.activecluster.election.ElectionStrategy

Elect a coordinator.

doElection(Cluster) - Method in class org.codehaus.activecluster.election.impl.BullyElectionStrategy

Elect a coordinator.

doElection() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

E

ELECTED_COORDINATOR - Static variable in class org.codehaus.activecluster.ClusterEvent

this node has been elected Coordinator

ElectionStrategy - interface org.codehaus.activecluster.election.ElectionStrategy.

Service Used by the Cluster to elect a coordinator.

F

FAILED_NODE - Static variable in class org.codehaus.activecluster.ClusterEvent

A node has failed due to a system/network error

G

getAcknowledgeMode() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

getActiveMQConnectionFactory() - Method in class org.codehaus.activecluster.impl.ActiveMQClusterFactory

getCluster() - Method in class org.codehaus.activecluster.ClusterEvent

getConnectionFactory() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

getDataTopicPrefix() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

getDeliveryMode() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

getDestination() - Method in interface org.codehaus.activecluster.Cluster

Returns the destination used to send a message to all members of the cluster

getDestination() - Method in interface org.codehaus.activecluster.Node

Access to the queue to send messages direct to this node.

getDestination() - Method in class org.codehaus.activecluster.impl.DefaultCluster

getDestination() - Method in class org.codehaus.activecluster.impl.NodeImpl

getElectionStrategy() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

getInactiveTime() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

getInactiveTime() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

getLocalNode() - Method in interface org.codehaus.activecluster.Cluster

The local Node which allows you to mutate the state or subscribe to the nodes temporary queue for inbound messages direct to the Node

getLocalNode() - Method in class org.codehaus.activecluster.impl.DefaultCluster

getName() - Method in interface org.codehaus.activecluster.Node

getName() - Method in class org.codehaus.activecluster.impl.NodeImpl

getNode() - Method in class org.codehaus.activecluster.ClusterEvent

getNodes() - Method in interface org.codehaus.activecluster.Cluster

A snapshot of the nodes in the cluster indexed by the Destination

getNodes() - Method in class org.codehaus.activecluster.impl.DefaultCluster

getNodes() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

getSession() - Method in class org.codehaus.activecluster.impl.DefaultCluster

getState() - Method in interface org.codehaus.activecluster.Node

getState() - Method in class org.codehaus.activecluster.impl.NodeImpl

getTimeMillis() - Method in class org.codehaus.activecluster.impl.StateServiceImpl

For performance we may wish to use a less granualar timing mechanism only updating the time every x millis since we're only using the time as a judge of when a node has not pinged for at least a few hundred millis etc.

getType() - Method in class org.codehaus.activecluster.ClusterEvent

I

isCoordinator() - Method in interface org.codehaus.activecluster.Node

isCoordinator() - Method in class org.codehaus.activecluster.impl.NodeImpl

isTransacted() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

isUseQueueForInbox() - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

K

keepAlive(Node) - Method in interface org.codehaus.activecluster.impl.StateService

Sends a keep alive to the cluster

keepAlive(Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

keepAlive(Node) - Method in class org.codehaus.activecluster.impl.StateServiceStub

L

LocalNode - interface org.codehaus.activecluster.LocalNode.

Represents the local (in process) node

lastKeepAlive - Variable in class org.codehaus.activecluster.impl.StateServiceImpl.NodeEntry

N

Node - interface org.codehaus.activecluster.Node.

Represents a node member in a cluster

NodeImpl - class org.codehaus.activecluster.impl.NodeImpl.

Default implementation of a remote Node

NodeImpl(Node) - Constructor for class org.codehaus.activecluster.impl.NodeImpl

Allow a node to be copied for sending it as a message

NodeImpl(Destination) - Constructor for class org.codehaus.activecluster.impl.NodeImpl

NodeImpl(Destination, Map) - Constructor for class org.codehaus.activecluster.impl.NodeImpl

NonReplicatedLocalNode - class org.codehaus.activecluster.impl.NonReplicatedLocalNode.

Default implementation of a local Node which doesn't have its state replicated

NonReplicatedLocalNode(Destination) - Constructor for class org.codehaus.activecluster.impl.NonReplicatedLocalNode

node - Variable in class org.codehaus.activecluster.impl.StateServiceImpl.NodeEntry

nodeAdded(Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

nodeFailed(Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

nodeUpdated(Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

O

onCoordinatorChanged(ClusterEvent) - Method in interface org.codehaus.activecluster.ClusterListener

An election has occurred and a new coordinator has been selected

onMessage(Message) - Method in class org.codehaus.activecluster.impl.StateConsumer

onNodeAdd(ClusterEvent) - Method in interface org.codehaus.activecluster.ClusterListener

A new node has been added

onNodeFailed(ClusterEvent) - Method in interface org.codehaus.activecluster.ClusterListener

A node has failed due to process or network failure

onNodeRemoved(ClusterEvent) - Method in interface org.codehaus.activecluster.ClusterListener

A node has been removed (a clean shutdown)

onNodeUpdate(ClusterEvent) - Method in interface org.codehaus.activecluster.ClusterListener

A node has updated its state

org.codehaus.activecluster - package org.codehaus.activecluster

ActiveCluster API for working with a simple cluster abstraction for building cluster algorithms like buddy systems, voting, master/slave protocols, electing a controller and so forth.

org.codehaus.activecluster.election - package org.codehaus.activecluster.election

org.codehaus.activecluster.election.impl - package org.codehaus.activecluster.election.impl

org.codehaus.activecluster.impl - package org.codehaus.activecluster.impl

Default implementation of ActiveCluster using standard JMS API to build the cluster.

P

pingRemoteNodes() - Method in class org.codehaus.activecluster.impl.NonReplicatedLocalNode

pingRemoteNodes() - Method in class org.codehaus.activecluster.impl.ReplicatedLocalNode

R

REMOVE_NODE - Static variable in class org.codehaus.activecluster.ClusterEvent

A node has left the Cluster

ReplicatedLocalNode - class org.codehaus.activecluster.impl.ReplicatedLocalNode.

Default implementation of a local Node which has its state replicated across the cluster

ReplicatedLocalNode(Destination, StateService) - Constructor for class org.codehaus.activecluster.impl.ReplicatedLocalNode

readExternal(ObjectInput) - Method in class org.codehaus.activecluster.ClusterEvent

read from stream

removeClusterListener(ClusterListener) - Method in interface org.codehaus.activecluster.Cluster

Removes a listener to cluster events

removeClusterListener(ClusterListener) - Method in class org.codehaus.activecluster.impl.DefaultCluster

removeClusterListener(ClusterListener) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

S

Service - interface org.codehaus.activecluster.Service.

Service represents some service of some kind with a simple start/stop lifecycle.

StateConsumer - class org.codehaus.activecluster.impl.StateConsumer.

A JMS MessageListener which processes inbound messages and applies them to a StateService

StateConsumer(StateService) - Constructor for class org.codehaus.activecluster.impl.StateConsumer

StateService - interface org.codehaus.activecluster.impl.StateService.

A client side proxy to the remove cluster

StateServiceImpl - class org.codehaus.activecluster.impl.StateServiceImpl.

Represents a node list

StateServiceImpl(Cluster, Object, Runnable, Timer, long) - Constructor for class org.codehaus.activecluster.impl.StateServiceImpl

StateServiceImpl.NodeEntry - class org.codehaus.activecluster.impl.StateServiceImpl.NodeEntry.

StateServiceImpl.NodeEntry() - Constructor for class org.codehaus.activecluster.impl.StateServiceImpl.NodeEntry

StateServiceStub - class org.codehaus.activecluster.impl.StateServiceStub.

A local stub for the state service which sends JMS messages to the cluster

StateServiceStub(Session, MessageProducer) - Constructor for class org.codehaus.activecluster.impl.StateServiceStub

send(Destination, Message) - Method in interface org.codehaus.activecluster.Cluster

Sends a message to a destination, which could be to the entire group or could be a single Node's destination

send(Destination, Message) - Method in class org.codehaus.activecluster.impl.DefaultCluster

setAcknowledgeMode(int) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

setActiveMQConnectionFactory(ActiveMQConnectionFactory) - Method in class org.codehaus.activecluster.impl.ActiveMQClusterFactory

setCluster(Cluster) - Method in class org.codehaus.activecluster.ClusterEvent

set the cluster

setConnectionFactory(ConnectionFactory) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

setCoordinator(boolean) - Method in class org.codehaus.activecluster.impl.NodeImpl

setDataTopicPrefix(String) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

setDeliveryMode(int) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

Sets the delivery mode of the group based producer

setElectionStrategy(ElectionStrategy) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

set the election strategy

setInactiveTime(long) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

setInactiveTime(long) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

setState(Map) - Method in interface org.codehaus.activecluster.LocalNode

Allows the local state to be modified, which will be replicated asynchronously around the cluster

setState(Map) - Method in class org.codehaus.activecluster.impl.NodeImpl

setState(Map) - Method in class org.codehaus.activecluster.impl.NonReplicatedLocalNode

setState(Map) - Method in class org.codehaus.activecluster.impl.ReplicatedLocalNode

setTransacted(boolean) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

setUseQueueForInbox(boolean) - Method in class org.codehaus.activecluster.impl.DefaultClusterFactory

shutdown(Node) - Method in interface org.codehaus.activecluster.impl.StateService

Sends a shutdown message to the cluster

shutdown(Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

shutdown(Node) - Method in class org.codehaus.activecluster.impl.StateServiceStub

start() - Method in interface org.codehaus.activecluster.Service

Called to start the service

start() - Method in class org.codehaus.activecluster.impl.DefaultCluster

start() - Method in class org.codehaus.activecluster.impl.ReplicatedLocalNode

state - Variable in class org.codehaus.activecluster.impl.NodeImpl

stateHasChanged(Node, Node) - Method in class org.codehaus.activecluster.impl.StateServiceImpl

stop() - Method in interface org.codehaus.activecluster.Service

Called to shutdown the service

stop() - Method in class org.codehaus.activecluster.impl.DefaultCluster

stop() - Method in class org.codehaus.activecluster.impl.ReplicatedLocalNode

T

toString() - Method in class org.codehaus.activecluster.ClusterEvent

toString() - Method in class org.codehaus.activecluster.impl.NodeImpl

U

UPDATE_NODE - Static variable in class org.codehaus.activecluster.ClusterEvent

existing node has updated it's state

W

waitForClusterToComplete(int, long) - Method in interface org.codehaus.activecluster.Cluster

wait until a the cardimality of the cluster is reaches the expected count.

waitForClusterToComplete(int, long) - Method in class org.codehaus.activecluster.impl.DefaultCluster

writeExternal(ObjectOutput) - Method in class org.codehaus.activecluster.ClusterEvent

dump on to a stream

A B C D E F G I K L N O P R S T U W