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 2015/10/09 10:05:20 UTC
camel git commit: [CAMEL-9204] Provide AMQP component factory method
for AMQP 1.0.
Repository: camel
Updated Branches:
refs/heads/master 015532438 -> 8b4b19faf
[CAMEL-9204]
Provide AMQP component factory method for AMQP 1.0.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8b4b19fa
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8b4b19fa
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8b4b19fa
Branch: refs/heads/master
Commit: 8b4b19faffd17f281db1a24ad5d32e497d35e940
Parents: 0155324
Author: Henryk Konsek <he...@gmail.com>
Authored: Fri Oct 9 10:05:08 2015 +0200
Committer: Henryk Konsek <he...@gmail.com>
Committed: Fri Oct 9 10:05:08 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/amqp/AMQPComponent.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/8b4b19fa/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
index 1d465bf..6397fd4 100644
--- a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
+++ b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPComponent.java
@@ -63,4 +63,10 @@ public class AMQPComponent extends JmsComponent {
return new AMQPComponent(ConnectionFactoryImpl.createFromURL(uri));
}
+ public static AMQPComponent amqp10Component(String uri) throws MalformedURLException {
+ ConnectionFactoryImpl connectionFactory = ConnectionFactoryImpl.createFromURL(uri);
+ connectionFactory.setTopicPrefix("topic://");
+ return new AMQPComponent(connectionFactory);
+ }
+
}