[CONF] Apache Camel > Maven 2 snapshot repository in pom
willem jiang created a page: Maven 2 snapshot repository in pom Camel In your pom.xml file you can add the Maven 2 snapshot repository if you want to try out the xxx-SNAPSHOT versions: apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true Then you can use the SNAPSHOT version of camel in your pom.xml: org.apache.camel camel-core 2.13-SNAPSHOT Apache Camel SNAPSHOTS https://repository.apache.org/content/repositories/snapshots/ Camel Plugins And the same setting for the plugin repository if you want to try the latest Apache Camel maven tools also: apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true Then you can use the SNAPSHOT version of mvn camel:run with this in your pom.xml: org.apache.camel camel-maven-plugin 2.13-SNAPSHOT View Online · Like Stop watching space · Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel > Download
willem jiang edited the page: Download ... To use this release in your maven project, the proper dependency configuration that you should use in your Maven POM is: Code Block xml org.apache.camel camel-core 2.12.2 ... See the Download Archives for all time releases. Include Page In Progress Snapshots Help us test the latest SNAPSHOTS
git commit: CAMEL-6868 Added addresses option to support clustered brokers
Updated Branches:
refs/heads/camel-2.12.x 66cbc0d36 -> df567f9c2
CAMEL-6868 Added addresses option to support clustered brokers
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/df567f9c
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/df567f9c
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/df567f9c
Branch: refs/heads/camel-2.12.x
Commit: df567f9c210c353d910a5bf11fad557eb0173826
Parents: 66cbc0d
Author: Willem Jiang
Authored: Mon Dec 16 14:53:43 2013 +0800
Committer: Willem Jiang
Committed: Mon Dec 16 15:13:12 2013 +0800
--
.../component/rabbitmq/RabbitMQEndpoint.java | 19 ++-
.../component/rabbitmq/RabbitMQEndpointTest.java | 10 ++
2 files changed, 28 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/camel/blob/df567f9c/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
--
diff --git
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
index f54f41f..338c1c5 100644
---
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
+++
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
@@ -24,6 +24,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Address;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Envelope;
@@ -54,6 +55,7 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
private String exchangeName;
private String exchangeType = "direct";
private String routingKey;
+private Address[] addresses;
public RabbitMQEndpoint() {
}
@@ -107,7 +109,11 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
}
factory.setHost(getHostname());
factory.setPort(getPortNumber());
-return factory.newConnection(executor);
+if (getAddresses() == null) {
+return factory.newConnection(executor);
+} else {
+return factory.newConnection(executor, getAddresses());
+}
}
@Override
@@ -239,4 +245,15 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
public boolean isBridgeEndpoint() {
return bridgeEndpoint;
}
+
+public void setAddresses(String addresses) {
+Address[] addressArray = Address.parseAddresses(addresses);
+if (addressArray.length > 0) {
+this.addresses = addressArray;
+}
+}
+
+public Address[] getAddresses() {
+return addresses;
+}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/df567f9c/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
--
diff --git
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
index 2f30177..9f22e92 100644
---
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
+++
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
@@ -24,6 +24,7 @@ import java.util.UUID;
import java.util.concurrent.ThreadPoolExecutor;
import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Address;
import com.rabbitmq.client.Envelope;
import com.rabbitmq.client.impl.LongStringHelper;
import org.apache.camel.Exchange;
@@ -111,4 +112,13 @@ public class RabbitMQEndpointTest extends CamelTestSupport
{
assertTrue(endpoint.isSingleton());
}
+
+@Test
+public void brokerEndpointAddressesSettings() throws Exception {
+RabbitMQEndpoint endpoint =
context.getEndpoint("rabbitmq:localhost/exchange?addresses=server1:12345,server2:12345",
RabbitMQEndpoint.class);
+assertEquals("Wrong size of endpoint addresses.", 2,
endpoint.getAddresses().length);
+assertEquals("Get a wrong endpoint address.", new Address("server1",
12345), endpoint.getAddresses()[0]);
+assertEquals("Get a wrong endpoint address.", new Address("server2",
12345), endpoint.getAddresses()[1]);
+
+}
}
git commit: CAMEL-6868 Added addresses option to support clustered brokers
Updated Branches:
refs/heads/master 15e1077d2 -> 2e7a7c8ad
CAMEL-6868 Added addresses option to support clustered brokers
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2e7a7c8a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2e7a7c8a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2e7a7c8a
Branch: refs/heads/master
Commit: 2e7a7c8ad81843a65cb405ca4c19473153dbf11f
Parents: 15e1077
Author: Willem Jiang
Authored: Mon Dec 16 14:53:43 2013 +0800
Committer: Willem Jiang
Committed: Mon Dec 16 14:53:43 2013 +0800
--
.../component/rabbitmq/RabbitMQEndpoint.java | 19 ++-
.../component/rabbitmq/RabbitMQEndpointTest.java | 10 ++
2 files changed, 28 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/camel/blob/2e7a7c8a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
--
diff --git
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
index f54f41f..338c1c5 100644
---
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
+++
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
@@ -24,6 +24,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Address;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Envelope;
@@ -54,6 +55,7 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
private String exchangeName;
private String exchangeType = "direct";
private String routingKey;
+private Address[] addresses;
public RabbitMQEndpoint() {
}
@@ -107,7 +109,11 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
}
factory.setHost(getHostname());
factory.setPort(getPortNumber());
-return factory.newConnection(executor);
+if (getAddresses() == null) {
+return factory.newConnection(executor);
+} else {
+return factory.newConnection(executor, getAddresses());
+}
}
@Override
@@ -239,4 +245,15 @@ public class RabbitMQEndpoint extends DefaultEndpoint {
public boolean isBridgeEndpoint() {
return bridgeEndpoint;
}
+
+public void setAddresses(String addresses) {
+Address[] addressArray = Address.parseAddresses(addresses);
+if (addressArray.length > 0) {
+this.addresses = addressArray;
+}
+}
+
+public Address[] getAddresses() {
+return addresses;
+}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/2e7a7c8a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
--
diff --git
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
index 2f30177..9f22e92 100644
---
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
+++
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java
@@ -24,6 +24,7 @@ import java.util.UUID;
import java.util.concurrent.ThreadPoolExecutor;
import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Address;
import com.rabbitmq.client.Envelope;
import com.rabbitmq.client.impl.LongStringHelper;
import org.apache.camel.Exchange;
@@ -111,4 +112,13 @@ public class RabbitMQEndpointTest extends CamelTestSupport
{
assertTrue(endpoint.isSingleton());
}
+
+@Test
+public void brokerEndpointAddressesSettings() throws Exception {
+RabbitMQEndpoint endpoint =
context.getEndpoint("rabbitmq:localhost/exchange?addresses=server1:12345,server2:12345",
RabbitMQEndpoint.class);
+assertEquals("Wrong size of endpoint addresses.", 2,
endpoint.getAddresses().length);
+assertEquals("Get a wrong endpoint address.", new Address("server1",
12345), endpoint.getAddresses()[0]);
+assertEquals("Get a wrong endpoint address.", new Address("server2",
12345), endpoint.getAddresses()[1]);
+
+}
}
buildbot failure in ASF Buildbot on camel-site-production
The Buildbot has detected a new failure on builder camel-site-production while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/camel-site-production/builds/15276 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: bb-cms-slave Build Reason: The Nightly scheduler named 'camel-site-production' triggered this build Build Source Stamp: [branch camel/website] HEAD Blamelist: BUILD FAILED: failed compile sincerely, -The Buildbot
[CONF] Apache Camel > Download
willem jiang edited the page: Download ... To use this release in your maven project, the proper dependency configuration that you should use in your Maven POM is: Code Block xml org.apache.camel camel-core 2.12.2 ... See the Download Archives for all time releases. Include Page In Progress Snapshots Help us test the latest SNAPSHOTS
[CONF] Apache Camel > How to set up Camel Maven 2 snapshot repository in pom
willem jiang created a page: How to set up Camel Maven 2 snapshot repository in pom Camel In your pom.xml file you can add the Maven 2 snapshot repository if you want to try out the xxx-SNAPSHOT versions: apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true Then you can use the SNAPSHOT version of camel in your pom.xml: org.apache.camel camel-core 2.13-SNAPSHOT Apache Camel SNAPSHOTS https://repository.apache.org/content/repositories/snapshots/ Camel Plugins And the same setting for the plugin repository if you want to try the latest Apache Camel maven tools also: apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true Then you can use the SNAPSHOT version of mvn camel:run with this in your pom.xml: org.apache.camel camel-maven-plugin 2.13-SNAPSHOT View Online · Like Stop watching space · Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel > Maven 2 snapshot repository in pom
willem jiang created a page: Maven 2 snapshot repository in pom Camel In your pom.xml file you can add the Maven 2 snapshot repository if you want to try out the xxx-SNAPSHOT versions: apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true Then you can use the SNAPSHOT version of camel in your pom.xml: org.apache.camel camel-core 2.13-SNAPSHOT Apache Camel SNAPSHOTS https://repository.apache.org/content/repositories/snapshots/ Camel Plugins And the same setting for the plugin repository if you want to try the latest Apache Camel maven tools also: apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true Then you can use the SNAPSHOT version of mvn camel:run with this in your pom.xml: org.apache.camel camel-maven-plugin 2.13-SNAPSHOT View Online · Like Stop watching space · Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel > Download
willem jiang edited the page: Download Comment: CAMEL-7070 ... To use this release in your maven project, the proper dependency configuration that you should use in your Maven POM is: Code Block xml org.apache.camel camel-core 2.12.2 ... See the Download Archives for all time releases. Include Page In Progress Snapshots Help us test the latest SNAPSHOTS
[CONF] Apache Camel > Download
willem jiang edited the page: Download Comment: CAMEL-7070 ... To use this release in your maven project, the proper dependency configuration that you should use in your Maven POM is: Code Block xml org.apache.camel camel-core 2.12.2 ... See the Download Archives for all time releases. Include Page In Progress Snapshots Help us test the latest SNAPSHOTS
buildbot success in ASF Buildbot on camel-site-production
The Buildbot has detected a restored build on builder camel-site-production while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/camel-site-production/builds/15274 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: bb-cms-slave Build Reason: The Nightly scheduler named 'camel-site-production' triggered this build Build Source Stamp: [branch camel/website] HEAD Blamelist: Build succeeded! sincerely, -The Buildbot
buildbot failure in ASF Buildbot on camel-site-production
The Buildbot has detected a new failure on builder camel-site-production while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/camel-site-production/builds/15272 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: bb-cms-slave Build Reason: The Nightly scheduler named 'camel-site-production' triggered this build Build Source Stamp: [branch camel/website] HEAD Blamelist: BUILD FAILED: failed compile sincerely, -The Buildbot
