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 <hekon...@gmail.com> Authored: Thu Dec 3 13:27:46 2015 +0100 Committer: Henryk Konsek <hekon...@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(); }
