You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/11/25 15:32:25 UTC
svn commit: r720506 - in /activemq/activemq-blaze/trunk/src:
main/java/org/apache/activeblaze/cluster/
main/java/org/apache/activeblaze/coordinated/
test/java/org/apache/activeblaze/cluster/
test/java/org/apache/activeblaze/coordinated/
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;
/**