Repository: camel Updated Branches: refs/heads/master d202a8cb8 -> 271e03e33
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4bca519b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4bca519b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4bca519b Branch: refs/heads/master Commit: 4bca519b4736965e2ec09c59f65bf8d12e667a54 Parents: d202a8c Author: Claus Ibsen <[email protected]> Authored: Mon Jun 13 08:33:35 2016 +0200 Committer: Claus Ibsen <[email protected]> Committed: Mon Jun 13 08:33:41 2016 +0200 ---------------------------------------------------------------------- components/camel-amqp/src/main/docs/amqp.adoc | 14 +++++++++-- .../springboot/AMQPComponentConfiguration.java | 26 ++++++++++++++++++++ 2 files changed, 38 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4bca519b/components/camel-amqp/src/main/docs/amqp.adoc ---------------------------------------------------------------------- diff --git a/components/camel-amqp/src/main/docs/amqp.adoc b/components/camel-amqp/src/main/docs/amqp.adoc index 4fccc8c..fb084f1 100644 --- a/components/camel-amqp/src/main/docs/amqp.adoc +++ b/components/camel-amqp/src/main/docs/amqp.adoc @@ -39,8 +39,9 @@ You can specify all of the various configuration options of the link:../../../../camel-jms/src/main/docs/readme.html[JMS] component after the destination name. + // component options: START -The AMQP component supports 72 options which are listed below. +The AMQP component supports 74 options which are listed below. @@ -62,6 +63,8 @@ The AMQP component supports 72 options which are listed below. | concurrentConsumers | int | Specifies the default number of concurrent consumers when consuming from JMS (not for request/reply over JMS). See also the maxMessagesPerTask option to control dynamic scaling up/down of threads. When doing request/reply over JMS then the option replyToConcurrentConsumers is used to control number of concurrent consumers on the reply message listener. | replyToConcurrentConsumers | int | Specifies the default number of concurrent consumers when doing request/reply over JMS. See also the maxMessagesPerTask option to control dynamic scaling up/down of threads. | connectionFactory | ConnectionFactory | Sets the default connection factory to be use +| username | String | Username to use with the ConnectionFactory. You can also configure username/password directly on the ConnectionFactory. +| password | String | Password to use with the ConnectionFactory. You can also configure username/password directly on the ConnectionFactory. | deliveryPersistent | boolean | Specifies whether persistent delivery is used by default. | deliveryMode | Integer | Specifies the delivery mode to be used. Possible values are Possibles values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2. | durableSubscriptionName | String | The durable subscriber name for specifying durable topic subscriptions. The clientId option must be configured as well. @@ -126,8 +129,10 @@ The AMQP component supports 72 options which are listed below. + + // endpoint options: START -The AMQP component supports 79 endpoint options which are listed below: +The AMQP component supports 83 endpoint options which are listed below: {% raw %} [width="100%",cols="2s,1,1m,1m,5",options="header"] @@ -136,6 +141,7 @@ The AMQP component supports 79 endpoint options which are listed below: | destinationType | common | queue | String | The kind of destination to use | destinationName | common | | String | *Required* Name of the queue or topic to use as destination | clientId | common | | String | Sets the JMS client ID to use. Note that this value if specified must be unique and can only be used by a single JMS connection instance. It is typically only required for durable topic subscriptions. If using Apache ActiveMQ you may prefer to use Virtual Topics instead. +| connectionFactory | common | | ConnectionFactory | The connection factory to be use. A connection factory must be configured either on the component or endpoint. | disableReplyTo | common | false | boolean | If true a producer will behave like a InOnly exchange with the exception that JMSReplyTo header is sent out and not be suppressed like in the case of InOnly. Like InOnly the producer will not wait for a reply. A consumer with this flag will behave like InOnly. This feature can be used to bridge InOut requests to another queue so that a route on the other queue will send its response directly back to the original JMSReplyTo. | durableSubscriptionName | common | | String | The durable subscriber name for specifying durable topic subscriptions. The clientId option must be configured as well. | jmsMessageType | common | | JmsMessageType | Allows you to force the use of a specific javax.jms.Message implementation for sending JMS messages. Possible values are: Bytes Map Object Stream Text. By default Camel would determine which JMS message type to use from the In body type. This option allows you to specify it. @@ -179,6 +185,7 @@ The AMQP component supports 79 endpoint options which are listed below: | replyToDestinationSelectorName | producer (advanced) | | String | Sets the JMS Selector using the fixed name to be used so you can filter out your own replies from the others when using a shared queue (that is if you are not using a temporary reply queue). | asyncStartListener | advanced | false | boolean | Whether to startup the JmsConsumer message listener asynchronously when starting a route. For example if a JmsConsumer cannot get a connection to a remote JMS broker then it may block while retrying and/or failover. This will cause Camel to block while starting routes. By setting this option to true you will let routes startup while the JmsConsumer connects to the JMS broker using a dedicated thread in asynchronous mode. If this option is used then beware that if the connection could not be established then an exception is logged at WARN level and the consumer will not be able to receive messages; You can then restart the route to retry. | asyncStopListener | advanced | false | boolean | Whether to stop the JmsConsumer message listener asynchronously when stopping a route. +| destinationResolver | advanced | | DestinationResolver | A pluggable org.springframework.jms.support.destination.DestinationResolver that allows you to use your own resolver (for example to lookup the real destination in a JNDI registry). | errorHandler | advanced | | ErrorHandler | Specifies a org.springframework.util.ErrorHandler to be invoked in case of any uncaught exceptions thrown while processing a Message. By default these exceptions will be logged at the WARN level if no errorHandler has been configured. You can configure logging level and whether stack traces should be logged using errorHandlerLoggingLevel and errorHandlerLogStackTrace options. This makes it much easier to configure than having to code a custom errorHandler. | errorHandlerLoggingLevel | advanced | WARN | LoggingLevel | Allows to configure the default errorHandler logging level for logging uncaught exceptions. | errorHandlerLogStackTrace | advanced | true | boolean | Allows to control whether stacktraces should be logged or not by the default errorHandler. @@ -207,6 +214,8 @@ The AMQP component supports 79 endpoint options which are listed below: | useMessageIDAsCorrelationID | advanced | false | boolean | Specifies whether JMSMessageID should always be used as JMSCorrelationID for InOut messages. | waitForProvisionCorrelationToBeUpdatedCounter | advanced | 50 | int | Number of times to wait for provisional correlation id to be updated to the actual correlation id when doing request/reply over JMS and when the option useMessageIDAsCorrelationID is enabled. | waitForProvisionCorrelationToBeUpdatedThreadSleepingTime | advanced | 100 | long | Interval in millis to sleep each time while waiting for provisional correlation id to be updated. +| password | security | | String | Password to use with the ConnectionFactory. You can also configure username/password directly on the ConnectionFactory. +| username | security | | String | Username to use with the ConnectionFactory. You can also configure username/password directly on the ConnectionFactory. | transacted | transaction | false | boolean | Specifies whether to use transacted mode | lazyCreateTransactionManager | transaction (advanced) | true | boolean | If true Camel will create a JmsTransactionManager if there is no transactionManager injected when option transacted=true. | transactionManager | transaction (advanced) | | PlatformTransactionManager | The Spring transaction manager to use. @@ -217,6 +226,7 @@ The AMQP component supports 79 endpoint options which are listed below: // endpoint options: END + [[AMQP-Usage]] Usage ^^^^^ http://git-wip-us.apache.org/repos/asf/camel/blob/4bca519b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java index 62e758e..3c81723 100644 --- a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java +++ b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java @@ -140,6 +140,16 @@ public class AMQPComponentConfiguration { */ private ConnectionFactory connectionFactory; /** + * Username to use with the ConnectionFactory. You can also configure + * username/password directly on the ConnectionFactory. + */ + private String username; + /** + * Password to use with the ConnectionFactory. You can also configure + * username/password directly on the ConnectionFactory. + */ + private String password; + /** * Specifies whether persistent delivery is used by default. */ private Boolean deliveryPersistent = false; @@ -644,6 +654,22 @@ public class AMQPComponentConfiguration { this.connectionFactory = connectionFactory; } + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + public Boolean getDeliveryPersistent() { return deliveryPersistent; }
