Return-Path: X-Original-To: apmail-camel-commits-archive@www.apache.org Delivered-To: apmail-camel-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A07DF181BD for ; Thu, 3 Dec 2015 11:15:56 +0000 (UTC) Received: (qmail 90724 invoked by uid 500); 3 Dec 2015 11:15:56 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 90680 invoked by uid 500); 3 Dec 2015 11:15:56 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 90671 invoked by uid 99); 3 Dec 2015 11:15:56 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Dec 2015 11:15:56 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 62F55E67E6; Thu, 3 Dec 2015 11:15:56 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: hekonsek@apache.org To: commits@camel.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: camel git commit: [camel-amqp] Added extra factory methods. Date: Thu, 3 Dec 2015 11:15:56 +0000 (UTC) Repository: camel Updated Branches: refs/heads/master ea41121d1 -> ec9a37b28 [camel-amqp] Added extra factory methods. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ec9a37b2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ec9a37b2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ec9a37b2 Branch: refs/heads/master Commit: ec9a37b2816325c916afb4661177b5ea28cd7c3a Parents: ea41121 Author: Henryk Konsek Authored: Thu Dec 3 12:15:50 2015 +0100 Committer: Henryk Konsek Committed: Thu Dec 3 12:15:50 2015 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/amqp/AMQPComponent.java | 10 ++++++++++ 1 file changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ec9a37b2/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 3100e20..8dcf7e6 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 @@ -29,6 +29,8 @@ import org.apache.qpid.jms.JmsConnectionFactory; */ public class AMQPComponent extends JmsComponent { + // Constructors + public AMQPComponent() { super(AMQPEndpoint.class); } @@ -45,6 +47,8 @@ public class AMQPComponent extends JmsComponent { setConnectionFactory(connectionFactory); } + // Factory methods + /** * Use {@code amqpComponent(String uri)} instead. */ @@ -61,4 +65,10 @@ public class AMQPComponent extends JmsComponent { return new AMQPComponent(connectionFactory); } + public static AMQPComponent amqpComponent(String uri, String username, String password) { + JmsConnectionFactory connectionFactory = new JmsConnectionFactory(username, password, uri); + connectionFactory.setTopicPrefix("topic://"); + return new AMQPComponent(connectionFactory); + } + }