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

Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.