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/12/03 13:27:51 UTC
camel git commit: [camel-amqp] Added missing topic pre-configuration.
Repository: camel
Updated Branches:
refs/heads/master 3be8c9536 -> aa99c809d
[camel-amqp] Added missing topic pre-configuration.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/aa99c809
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/aa99c809
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/aa99c809
Branch: refs/heads/master
Commit: aa99c809d2b52dd0c6ffdd29b305d6a6bb133fa0
Parents: 3be8c95
Author: Henryk Konsek <he...@gmail.com>
Authored: Thu Dec 3 13:27:46 2015 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Thu Dec 3 13:27:46 2015 +0100
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/amqp/AMQPComponent.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/aa99c809/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 dc4c2ed..6dd8226 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
@@ -55,7 +55,9 @@ public class AMQPComponent extends JmsComponent {
Set<AMQPConnectionDetails> connectionDetails = getCamelContext().getRegistry().findByType(AMQPConnectionDetails.class);
if (connectionDetails.size() == 1) {
AMQPConnectionDetails details = connectionDetails.iterator().next();
- setConnectionFactory(new JmsConnectionFactory(details.username(), details.password(), details.uri()));
+ JmsConnectionFactory connectionFactory = new JmsConnectionFactory(details.username(), details.password(), details.uri());
+ connectionFactory.setTopicPrefix("topic://");
+ setConnectionFactory(connectionFactory);
}
super.doStart();
}