Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactored package names to be org.apache.activecluster 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@359626 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2005-12-28 20:29:09 +00:00
parent e3c9b28275
commit 7356192be8
47 changed files with 162 additions and 121 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activecluster/maven.xml
View File

@ -31,7 +31,7 @@
<goal name="demo:A" prereqs="setclasspath"
description="Runs the simple ActiveCluster Demo">
<echo>Running the ActiveCluster demo...</echo>
<java classname="org.activecluster.ClusterDemo" fork="true">
<java classname="org.apache.activecluster.ClusterDemo" fork="true">
<classpath refid="test.classpath"/>
<sysproperty key="org.apache.commons.logging.simplelog.defaultlog" value="debug"/>
<arg value="A"/>
@ -41,7 +41,7 @@
<goal name="demo:B" prereqs="setclasspath"
description="Runs the simple ActiveCluster Demo">
<echo>Running the ActiveCluster demo...</echo>
<java classname="org.activecluster.ClusterDemo" fork="true">
<java classname="org.apache.activecluster.ClusterDemo" fork="true">
<classpath refid="test.classpath"/>
<arg value="B"/>
</java>
@ -54,7 +54,7 @@
<goal name="chat" prereqs="setclasspath"
description="Runs the ActiveCluster Chat Demo">
<echo>Running the ActiveCluster Chat demo...</echo>
<java classname="org.activecluster.ChatDemo" fork="true">
<java classname="org.apache.activecluster.ChatDemo" fork="true">
<classpath refid="test.classpath"/>
</java>
</goal>

12
activecluster/project.xml
View File

@ -11,27 +11,27 @@
<inceptionYear>2004</inceptionYear>
<package>org.activecluster</package>
<package>org.apache.activecluster</package>
<packageGroups>
<packageGroup>
<title>Core ActiveCluster API</title>
<packages>org.activecluster</packages>
<packages>org.apache.activecluster</packages>
</packageGroup>
<packageGroup>
<title>Group organisation protocols</title>
<packages>org.activecluster.group</packages>
<packages>org.apache.activecluster.group</packages>
</packageGroup>
<packageGroup>
<title>Election protocols</title>
<packages>org.activecluster.election</packages>
<packages>org.apache.activecluster.election</packages>
</packageGroup>
<packageGroup>
<title>ActiveMQ specific implementation classes</title>
<packages>org.activecluster.activemq</packages>
<packages>org.apache.activecluster.activemq</packages>
</packageGroup>
<packageGroup>
<title>Implementation classes</title>
<packages>org.activecluster.impl:org.activecluster.election.impl</packages>
<packages>org.apache.activecluster.impl:org.apache.activecluster.election.impl</packages>
</packageGroup>
</packageGroups>

5
activecluster/src/java/org/activecluster/Cluster.java → activecluster/src/java/org/apache/activecluster/Cluster.java
View File

@ -16,7 +16,7 @@
*
**/
package org.activecluster;
package org.apache.activecluster;
import java.io.Serializable;
import java.util.Map;
@ -29,7 +29,8 @@ import javax.jms.MessageConsumer;
import javax.jms.ObjectMessage;
import javax.jms.StreamMessage;
import javax.jms.TextMessage;
import org.activecluster.election.ElectionStrategy;
import org.apache.activecluster.election.ElectionStrategy;
/**
* Represents a logical connection to a cluster. From this object you can

2
activecluster/src/java/org/activecluster/ClusterEvent.java → activecluster/src/java/org/apache/activecluster/ClusterEvent.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import java.io.Externalizable;
import java.io.IOException;
import java.io.ObjectInput;

2
activecluster/src/java/org/activecluster/ClusterException.java → activecluster/src/java/org/apache/activecluster/ClusterException.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
/**

2
activecluster/src/java/org/activecluster/ClusterFactory.java → activecluster/src/java/org/apache/activecluster/ClusterFactory.java
View File

@ -16,7 +16,7 @@
*
**/
package org.activecluster;
package org.apache.activecluster;
import javax.jms.Destination;
import javax.jms.JMSException;

2
activecluster/src/java/org/activecluster/ClusterListener.java → activecluster/src/java/org/apache/activecluster/ClusterListener.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import java.util.EventListener;

2
activecluster/src/java/org/activecluster/DestinationMarshaller.java → activecluster/src/java/org/apache/activecluster/DestinationMarshaller.java
View File

@ -16,7 +16,7 @@
*
**/
package org.activecluster;
package org.apache.activecluster;
import javax.jms.Destination;

2
activecluster/src/java/org/activecluster/LocalNode.java → activecluster/src/java/org/apache/activecluster/LocalNode.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import javax.jms.JMSException;
import java.util.Map;

2
activecluster/src/java/org/activecluster/Node.java → activecluster/src/java/org/apache/activecluster/Node.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*
**/
package org.activecluster;
package org.apache.activecluster;
import java.util.Map;
import javax.jms.Destination;

2
activecluster/src/java/org/activecluster/Service.java → activecluster/src/java/org/apache/activecluster/Service.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import javax.jms.JMSException;

7
activecluster/src/java/org/activecluster/election/ElectionStrategy.java → activecluster/src/java/org/apache/activecluster/election/ElectionStrategy.java
View File

@ -14,11 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.election;
package org.apache.activecluster.election;
import javax.jms.JMSException;
import org.activecluster.Cluster;
import org.activecluster.Node;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.Node;
/**
* <p><code>Service</code> Used by the Cluster to elect a coordinator.</p>

8
activecluster/src/java/org/activecluster/election/impl/BullyElectionStrategy.java → activecluster/src/java/org/apache/activecluster/election/impl/BullyElectionStrategy.java
View File

@ -15,11 +15,11 @@
* limitations under the License.
*/
package org.activecluster.election.impl;
package org.apache.activecluster.election.impl;
import org.activecluster.Cluster;
import org.activecluster.Node;
import org.activecluster.election.ElectionStrategy;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.Node;
import org.apache.activecluster.election.ElectionStrategy;
import javax.jms.JMSException;
import java.util.Iterator;

4
activecluster/src/java/org/activecluster/group/BuddyGroupModel.java → activecluster/src/java/org/apache/activecluster/group/BuddyGroupModel.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.Node;
import org.apache.activecluster.Node;
/**
* A kind of {@link GroupModel} in which every {@link Node} has its

4
activecluster/src/java/org/activecluster/group/Group.java → activecluster/src/java/org/apache/activecluster/group/Group.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.Node;
import org.apache.activecluster.Node;
import java.util.ArrayList;
import java.util.List;

6
activecluster/src/java/org/activecluster/group/GroupClusterListener.java → activecluster/src/java/org/apache/activecluster/group/GroupClusterListener.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.ClusterEvent;
import org.activecluster.ClusterListener;
import org.apache.activecluster.ClusterEvent;
import org.apache.activecluster.ClusterListener;
/**
* A {@link ClusterListener} which maintains a {@link GroupModel} implementation

4
activecluster/src/java/org/activecluster/group/GroupModel.java → activecluster/src/java/org/apache/activecluster/group/GroupModel.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.Node;
import org.apache.activecluster.Node;
import java.util.ArrayList;
import java.util.HashMap;

4
activecluster/src/java/org/activecluster/group/MasterZoneFilter.java → activecluster/src/java/org/apache/activecluster/group/MasterZoneFilter.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.Node;
import org.apache.activecluster.Node;
import java.util.List;

2
activecluster/src/java/org/activecluster/group/Membership.java → activecluster/src/java/org/apache/activecluster/group/Membership.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
/**
* Represents the membership of a Group for a Node

4
activecluster/src/java/org/activecluster/group/NodeFilter.java → activecluster/src/java/org/apache/activecluster/group/NodeFilter.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.Node;
import org.apache.activecluster.Node;
/**
* Represents a filter on a Node to allow a pluggable

4
activecluster/src/java/org/activecluster/group/NodeMemberships.java → activecluster/src/java/org/apache/activecluster/group/NodeMemberships.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import org.activecluster.Node;
import org.apache.activecluster.Node;
import java.util.HashMap;
import java.util.Map;

2
activecluster/src/java/org/activecluster/group/package.html → activecluster/src/java/org/apache/activecluster/group/package.html
View File

@ -3,7 +3,7 @@
</head>
<body>
Contains Group Organsisation models and policies for arranging {@link org.activecluster.Node} instances into
Contains Group Organsisation models and policies for arranging {@link org.apache.activecluster.Node} instances into
groups, such as buddy-groups (failover nodes) or master/slave groups for High Availability (HA) protocols.
</body>

10
activecluster/src/java/org/activecluster/impl/ActiveMQClusterFactory.java → activecluster/src/java/org/apache/activecluster/impl/ActiveMQClusterFactory.java
View File

@ -14,20 +14,20 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import org.activecluster.impl.DefaultClusterFactory;
import org.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activecluster.impl.DefaultClusterFactory;
/**
* An implementation of {@link org.activecluster.ClusterFactory} using
* An implementation of {@link org.apache.activecluster.ClusterFactory} using
* <a href="http://activemq.codehaus.org/">ActiveMQ</a>
*
* @version $Revision: 1.4 $
*/
public class ActiveMQClusterFactory extends DefaultClusterFactory {
public static String DEFAULT_CLUSTER_URL = "peer://org.activecluster?persistent=false";
public static String DEFAULT_CLUSTER_URL = "peer://org.apache.activecluster?persistent=false";
public ActiveMQClusterFactory() {
super(new ActiveMQConnectionFactory(DEFAULT_CLUSTER_URL));

15
activecluster/src/java/org/activecluster/impl/DefaultCluster.java → activecluster/src/java/org/apache/activecluster/impl/DefaultCluster.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.io.Serializable;
import java.util.Map;
@ -32,12 +32,13 @@ import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.StreamMessage;
import javax.jms.TextMessage;
import org.activecluster.Cluster;
import org.activecluster.ClusterListener;
import org.activecluster.DestinationMarshaller;
import org.activecluster.LocalNode;
import org.activecluster.Service;
import org.activecluster.election.ElectionStrategy;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterListener;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.activecluster.LocalNode;
import org.apache.activecluster.Service;
import org.apache.activecluster.election.ElectionStrategy;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.*;

12
activecluster/src/java/org/activecluster/impl/DefaultClusterFactory.java → activecluster/src/java/org/apache/activecluster/impl/DefaultClusterFactory.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.util.Timer;
import javax.jms.Connection;
@ -25,11 +25,11 @@ import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.Topic;
import org.activecluster.Cluster;
import org.activecluster.ClusterException;
import org.activecluster.ClusterFactory;
import org.activecluster.DestinationMarshaller;
import org.activemq.util.IdGenerator;
import org.apache.activemq.util.IdGenerator;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterException;
import org.apache.activecluster.ClusterFactory;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

6
activecluster/src/java/org/activecluster/impl/DefaultDestinationMarshaller.java → activecluster/src/java/org/apache/activecluster/impl/DefaultDestinationMarshaller.java
View File

@ -16,14 +16,14 @@
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.Topic;
import org.activecluster.DestinationMarshaller;
import org.activemq.command.ActiveMQTopic;
import org.apache.activemq.command.ActiveMQTopic;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

7
activecluster/src/java/org/activecluster/impl/NodeImpl.java → activecluster/src/java/org/apache/activecluster/impl/NodeImpl.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.io.IOException;
import java.io.ObjectInput;
@ -23,8 +23,9 @@ import java.io.ObjectOutput;
import java.util.HashMap;
import java.util.Map;
import javax.jms.Destination;
import org.activecluster.DestinationMarshaller;
import org.activecluster.Node;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.activecluster.Node;
/**

7
activecluster/src/java/org/activecluster/impl/NodeState.java → activecluster/src/java/org/apache/activecluster/impl/NodeState.java
View File

@ -15,15 +15,16 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.io.Externalizable;
import java.io.IOException;
import java.io.ObjectInput;
import java.io.ObjectOutput;
import java.util.Map;
import org.activecluster.DestinationMarshaller;
import org.activecluster.Node;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.activecluster.Node;
/**
* Default implementation of a remote Node
*

5
activecluster/src/java/org/activecluster/impl/NonReplicatedLocalNode.java → activecluster/src/java/org/apache/activecluster/impl/NonReplicatedLocalNode.java
View File

@ -15,11 +15,12 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.util.Map;
import javax.jms.Destination;
import org.activecluster.LocalNode;
import org.apache.activecluster.LocalNode;
/**
* Default implementation of a local Node which doesn't

7
activecluster/src/java/org/activecluster/impl/ReplicatedLocalNode.java → activecluster/src/java/org/apache/activecluster/impl/ReplicatedLocalNode.java
View File

@ -15,13 +15,14 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.util.Map;
import javax.jms.Destination;
import javax.jms.JMSException;
import org.activecluster.LocalNode;
import org.activecluster.Service;
import org.apache.activecluster.LocalNode;
import org.apache.activecluster.Service;
/**

6
activecluster/src/java/org/activecluster/impl/StateConsumer.java → activecluster/src/java/org/apache/activecluster/impl/StateConsumer.java
View File

@ -15,12 +15,12 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.activecluster.Node;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.activecluster.DestinationMarshaller;
import org.activecluster.Node;
import javax.jms.Message;
import javax.jms.MessageListener;

4
activecluster/src/java/org/activecluster/impl/StateService.java → activecluster/src/java/org/apache/activecluster/impl/StateService.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import org.activecluster.Node;
import org.apache.activecluster.Node;
/**

15
activecluster/src/java/org/activecluster/impl/StateServiceImpl.java → activecluster/src/java/org/apache/activecluster/impl/StateServiceImpl.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import java.util.HashMap;
import java.util.Iterator;
@ -26,12 +26,13 @@ import java.util.TimerTask;
import java.util.Map.Entry;
import javax.jms.Destination;
import javax.jms.JMSException;
import org.activecluster.Cluster;
import org.activecluster.ClusterEvent;
import org.activecluster.ClusterListener;
import org.activecluster.Node;
import org.activecluster.election.ElectionStrategy;
import org.activecluster.election.impl.BullyElectionStrategy;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterEvent;
import org.apache.activecluster.ClusterListener;
import org.apache.activecluster.Node;
import org.apache.activecluster.election.ElectionStrategy;
import org.apache.activecluster.election.impl.BullyElectionStrategy;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;

6
activecluster/src/java/org/activecluster/impl/StateServiceStub.java → activecluster/src/java/org/apache/activecluster/impl/StateServiceStub.java
View File

@ -15,12 +15,12 @@
* limitations under the License.
*
**/
package org.activecluster.impl;
package org.apache.activecluster.impl;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.activecluster.Node;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.activecluster.DestinationMarshaller;
import org.activecluster.Node;
import javax.jms.JMSException;
import javax.jms.Message;

0
activecluster/src/java/org/activecluster/impl/package.html → activecluster/src/java/org/apache/activecluster/impl/package.html
View File

0
activecluster/src/java/org/activecluster/package.html → activecluster/src/java/org/apache/activecluster/package.html
View File

10
activecluster/src/test/org/activecluster/ChatDemo.java → activecluster/src/test/org/apache/activecluster/ChatDemo.java
View File

@ -14,14 +14,20 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.HashMap;
import java.util.Map;
import javax.jms.JMSException;
import org.activecluster.impl.ActiveMQClusterFactory;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterEvent;
import org.apache.activecluster.ClusterException;
import org.apache.activecluster.ClusterFactory;
import org.apache.activecluster.ClusterListener;
import org.apache.activecluster.impl.ActiveMQClusterFactory;
/**
* @version $Revision: 1.2 $

13
activecluster/src/test/org/activecluster/ClusterDemo.java → activecluster/src/test/org/apache/activecluster/ClusterDemo.java
View File

@ -14,12 +14,15 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import org.activecluster.impl.ActiveMQClusterFactory;
import org.activecluster.impl.DefaultClusterFactory;
import org.activecluster.election.ElectionStrategy;
import org.activecluster.election.impl.BullyElectionStrategy;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterException;
import org.apache.activecluster.ClusterFactory;
import org.apache.activecluster.election.ElectionStrategy;
import org.apache.activecluster.election.impl.BullyElectionStrategy;
import org.apache.activecluster.impl.ActiveMQClusterFactory;
import org.apache.activecluster.impl.DefaultClusterFactory;
import javax.jms.JMSException;
import java.io.BufferedReader;

13
activecluster/src/test/org/activecluster/ClusterFunctionTest.java → activecluster/src/test/org/apache/activecluster/ClusterFunctionTest.java
View File

@ -16,7 +16,7 @@
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import java.util.HashMap;
import java.util.Map;
import javax.jms.Connection;
@ -25,13 +25,14 @@ import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import junit.framework.TestCase;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterEvent;
import org.apache.activecluster.ClusterListener;
import org.apache.activecluster.impl.DefaultClusterFactory;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.activecluster.Cluster;
import org.activecluster.ClusterEvent;
import org.activecluster.ClusterListener;
import org.activecluster.impl.DefaultClusterFactory;
import org.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
/**
* Test ActiveCluster, ActiveMQ, with an eye to putting WADI on top of them.

6
activecluster/src/test/org/activecluster/ClusterTest.java → activecluster/src/test/org/apache/activecluster/ClusterTest.java
View File

@ -15,13 +15,17 @@
* limitations under the License.
*
**/
package org.activecluster;
package org.apache.activecluster;
import java.util.List;
import java.util.Map;
import javax.jms.Destination;
import javax.jms.Message;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.LocalNode;
import org.apache.activecluster.Node;
/**
* @version $Revision: 1.4 $
*/

6
activecluster/src/test/org/activecluster/ClusterTestSupport.java → activecluster/src/test/org/apache/activecluster/ClusterTestSupport.java
View File

@ -15,9 +15,11 @@
* limitations under the License.
*
**/
package org.activecluster;
package org.apache.activecluster;
import org.activecluster.impl.ActiveMQClusterFactory;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.Node;
import org.apache.activecluster.impl.ActiveMQClusterFactory;
import javax.jms.Destination;
import javax.jms.JMSException;

2
activecluster/src/test/org/activecluster/StubMessageListener.java → activecluster/src/test/org/apache/activecluster/StubMessageListener.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import javax.jms.Message;
import javax.jms.MessageListener;

8
activecluster/src/test/org/activecluster/TestSupport.java → activecluster/src/test/org/apache/activecluster/TestSupport.java
View File

@ -15,7 +15,7 @@
* limitations under the License.
*
**/
package org.activecluster;
package org.apache.activecluster;
import junit.framework.TestCase;
@ -23,7 +23,11 @@ import javax.jms.JMSException;
import java.util.Iterator;
import java.util.Map;
import org.activecluster.impl.ActiveMQClusterFactory;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterException;
import org.apache.activecluster.ClusterFactory;
import org.apache.activecluster.Node;
import org.apache.activecluster.impl.ActiveMQClusterFactory;
/**
* @version $Revision: 1.2 $

7
activecluster/src/test/org/activecluster/TestingClusterListener.java → activecluster/src/test/org/apache/activecluster/TestingClusterListener.java
View File

@ -14,9 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster;
package org.apache.activecluster;
import org.activecluster.impl.DefaultCluster;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterEvent;
import org.apache.activecluster.ClusterListener;
import org.apache.activecluster.impl.DefaultCluster;
/**
* @version $Revision: 1.2 $

6
activecluster/src/test/org/activecluster/group/BuddyGroupModelTest.java → activecluster/src/test/org/apache/activecluster/group/BuddyGroupModelTest.java
View File

@ -14,10 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import java.util.List;
import org.apache.activecluster.group.BuddyGroupModel;
import org.apache.activecluster.group.Group;
import org.apache.activecluster.group.GroupModel;
/**
* @version $Revision: 1.4 $
*/

4
activecluster/src/test/org/activecluster/group/GroupModelTest.java → activecluster/src/test/org/apache/activecluster/group/GroupModelTest.java
View File

@ -14,10 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.activecluster.group;
package org.apache.activecluster.group;
import java.util.List;
import org.apache.activecluster.group.Group;
/**
* @version $Revision: 1.4 $
*/

20
activecluster/src/test/org/activecluster/group/GroupTestSupport.java → activecluster/src/test/org/apache/activecluster/group/GroupTestSupport.java
View File

@ -15,18 +15,22 @@
* limitations under the License.
*
**/
package org.activecluster.group;
package org.apache.activecluster.group;
import java.util.HashMap;
import java.util.Map;
import junit.framework.TestCase;
import org.activecluster.Cluster;
import org.activecluster.ClusterEvent;
import org.activecluster.ClusterListener;
import org.activecluster.DestinationMarshaller;
import org.activecluster.Node;
import org.activecluster.impl.DefaultDestinationMarshaller;
import org.activecluster.impl.NodeImpl;
import org.apache.activecluster.Cluster;
import org.apache.activecluster.ClusterEvent;
import org.apache.activecluster.ClusterListener;
import org.apache.activecluster.DestinationMarshaller;
import org.apache.activecluster.Node;
import org.apache.activecluster.group.Group;
import org.apache.activecluster.group.GroupClusterListener;
import org.apache.activecluster.group.GroupModel;
import org.apache.activecluster.impl.DefaultDestinationMarshaller;
import org.apache.activecluster.impl.NodeImpl;
/**
* A base class for Group model testing