You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by he...@apache.org on 2014/02/17 14:05:40 UTC
git commit: Made JGroups cluster tests cluster-friendly (so they
could be executed concurrently by Jenkins).
Repository: camel
Updated Branches:
refs/heads/master a31868abb -> b1f123361
Made JGroups cluster tests cluster-friendly (so they could be executed concurrently by Jenkins).
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b1f12336
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b1f12336
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b1f12336
Branch: refs/heads/master
Commit: b1f123361ae0db08b24530cad4be551680d5c7cc
Parents: a31868a
Author: Henryk Konsek <he...@gmail.com>
Authored: Mon Feb 17 14:05:13 2014 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Mon Feb 17 14:05:13 2014 +0100
----------------------------------------------------------------------
.../component/jgroups/JGroupsClusterTest.java | 17 ++++++++++++-----
1 file changed, 12 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/b1f12336/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsClusterTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsClusterTest.java b/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsClusterTest.java
index 30fc1db..0aa1228 100644
--- a/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsClusterTest.java
+++ b/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsClusterTest.java
@@ -16,6 +16,9 @@
*/
package org.apache.camel.component.jgroups;
+import static java.lang.String.format;
+import static java.util.UUID.randomUUID;
+
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
@@ -29,21 +32,25 @@ import static org.apache.camel.component.jgroups.JGroupsFilters.dropNonCoordinat
public class JGroupsClusterTest extends Assert {
+ // Tested state
+
+ String master;
+
+ int nominationCount;
+
// Routing fixtures
+ String jgroupsEndpoint = format("jgroups:%s?enableViewMessages=true", randomUUID());
+
DefaultCamelContext firstCamelContext;
DefaultCamelContext secondCamelContext;
- String master;
-
- int nominationCount;
-
class Builder extends RouteBuilder {
@Override
public void configure() throws Exception {
- from("jgroups:cluster?enableViewMessages=true").
+ from(jgroupsEndpoint).
filter(dropNonCoordinatorViews()).
process(new Processor() {
@Override