Author: rajdavies
Date: Tue Nov 25 06:32:24 2008
New Revision: 720506
URL: http://svn.apache.org/viewvc?rev=720506&view=rev
Log:
rename coordinated package to cluster
Added:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/
- copied from r720504,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannel.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannel.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelFactory.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelFactory.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelImpl.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelImpl.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupConfiguration.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupConfiguration.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatedGroup.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatedGroup.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatorChangedListener.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatorChangedListener.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/ElectionService.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/ElectionService.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/GroupState.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/GroupState.java
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/package.html
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/package.html
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/cluster/
- copied from r720504,
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/coordinated/
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelTest.java
- copied, changed from r720505,
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelTest.java
Removed:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/coordinated/
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannel.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannel.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannel.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannel.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannel.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannel.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannel.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import org.apache.activeblaze.group.BlazeGroupChannel;
import org.apache.activeblaze.group.Member;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelFactory.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelFactory.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelFactory.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelFactory.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelFactory.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelFactory.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelFactory.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import org.apache.activeblaze.group.BlazeGroupChannelFactory;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelImpl.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelImpl.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelImpl.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelImpl.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelImpl.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelImpl.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelImpl.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import java.net.URI;
import org.apache.activeblaze.group.BlazeGroupChannelImpl;
@@ -49,7 +49,7 @@
/**
* @param l
* @throws Exception
- * @see
org.apache.activeblaze.coordinated.BlazeCoordinatedGroupChannel#addCoordinatorChangedListener(org.apache.activeblaze.coordinated.CoordinatorChangedListener)
+ * @see
org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannel#addCoordinatorChangedListener(org.apache.activeblaze.cluster.CoordinatorChangedListener)
*/
public void addCoordinatorChangedListener(CoordinatorChangedListener l)
throws Exception {
init();
@@ -59,7 +59,7 @@
/**
* @return
* @throws Exception
- * @see
org.apache.activeblaze.coordinated.BlazeCoordinatedGroupChannel#getCoordinator()
+ * @see
org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannel#getCoordinator()
*/
public Member getCoordinator() throws Exception {
init();
@@ -69,7 +69,7 @@
/**
* @return
* @throws Exception
- * @see
org.apache.activeblaze.coordinated.BlazeCoordinatedGroupChannel#isCoordinator()
+ * @see
org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannel#isCoordinator()
*/
public boolean isCoordinator() throws Exception {
init();
@@ -79,7 +79,7 @@
/**
* @param l
* @throws Exception
- * @see
org.apache.activeblaze.coordinated.BlazeCoordinatedGroupChannel#removeMemberChangedListener(org.apache.activeblaze.coordinated.CoordinatorChangedListener)
+ * @see
org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannel#removeMemberChangedListener(org.apache.activeblaze.cluster.CoordinatorChangedListener)
*/
public void removeCoordinatorChangedListener(CoordinatorChangedListener l)
throws Exception {
init();
@@ -88,7 +88,7 @@
/**
* @return
- * @see
org.apache.activeblaze.coordinated.BlazeCoordinatedGroupChannel#getCoordinatedGroupConfiguration()
+ * @see
org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannel#getCoordinatedGroupConfiguration()
*/
public BlazeCoordinatedGroupConfiguration
getCoordinatedGroupConfiguration() {
return (BlazeCoordinatedGroupConfiguration) getGroupConfiguration();
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupConfiguration.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupConfiguration.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupConfiguration.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupConfiguration.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupConfiguration.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupConfiguration.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupConfiguration.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import org.apache.activeblaze.BlazeConfiguration;
import org.apache.activeblaze.group.BlazeGroupConfiguration;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatedGroup.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatedGroup.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatedGroup.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatedGroup.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatedGroup.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatedGroup.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatedGroup.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import java.util.ArrayList;
import java.util.Collections;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatorChangedListener.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatorChangedListener.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatorChangedListener.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatorChangedListener.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatorChangedListener.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/CoordinatorChangedListener.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/CoordinatorChangedListener.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import org.apache.activeblaze.group.Member;
import org.apache.activeblaze.group.MemberChangedListener;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/ElectionService.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/ElectionService.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/ElectionService.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/ElectionService.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/ElectionService.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/ElectionService.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/ElectionService.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import java.util.ArrayList;
import java.util.Collections;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/GroupState.java
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/GroupState.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/GroupState.java?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/GroupState.java&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/GroupState.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/GroupState.java
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/GroupState.java
Tue Nov 25 06:32:24 2008
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import java.util.Collection;
import java.util.Map;
Copied:
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/package.html
(from r720505,
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/package.html)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/package.html?p2=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/package.html&p1=activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/package.html&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/coordinated/package.html
(original)
+++
activemq/activemq-blaze/trunk/src/main/java/org/apache/activeblaze/cluster/package.html
Tue Nov 25 06:32:24 2008
@@ -19,7 +19,7 @@
</head>
<body>
-Coordinated group messaging
+cluster group messaging, cluster state and master election
</body>
</html>
\ No newline at end of file
Copied:
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelTest.java
(from r720505,
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelTest.java)
URL:
http://svn.apache.org/viewvc/activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelTest.java?p2=activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelTest.java&p1=activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelTest.java&r1=720505&r2=720506&rev=720506&view=diff
==============================================================================
---
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/coordinated/BlazeCoordinatedGroupChannelTest.java
(original)
+++
activemq/activemq-blaze/trunk/src/test/java/org/apache/activeblaze/cluster/BlazeCoordinatedGroupChannelTest.java
Tue Nov 25 06:32:24 2008
@@ -14,10 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.activeblaze.coordinated;
+package org.apache.activeblaze.cluster;
import java.util.ArrayList;
import java.util.List;
+import org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannel;
+import org.apache.activeblaze.cluster.BlazeCoordinatedGroupChannelFactory;
import junit.framework.TestCase;
/**