camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [camel] 04/06: Regen
Date Sat, 21 Oct 2017 19:29:53 GMT
This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 38b78e96e21f05aff79e190a85426bd3f2122c42
Author: Claus Ibsen <davsclaus@apache.org>
AuthorDate: Sat Oct 21 09:43:22 2017 +0200

    Regen
---
 .../camel-amqp/src/main/docs/amqp-component.adoc       |  6 ++++--
 .../amqp/springboot/AMQPComponentConfiguration.java    | 18 ++++++++++++++++++
 2 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/components/camel-amqp/src/main/docs/amqp-component.adoc b/components/camel-amqp/src/main/docs/amqp-component.adoc
index be9bc8b..ae5566d 100644
--- a/components/camel-amqp/src/main/docs/amqp-component.adoc
+++ b/components/camel-amqp/src/main/docs/amqp-component.adoc
@@ -38,7 +38,7 @@ link:../../../../camel-jms/src/main/docs/readme.html[JMS] component after
the de
 
 
 // component options: START
-The AMQP component supports 78 options which are listed below.
+The AMQP component supports 79 options which are listed below.
 
 
 
@@ -121,6 +121,7 @@ The AMQP component supports 78 options which are listed below.
 | *subscriptionDurable* (consumer) | Set whether to make the subscription durable. The durable
subscription name to be used can be specified through the subscriptionName property. Default
is false. Set this to true to register a durable subscription typically in combination with
a subscriptionName value (unless your message listener class name is good enough as subscription
name). Only makes sense when listening to a topic (pub-sub domain) therefore this method switches
the pubSubDomain  [...]
 | *subscriptionShared* (consumer) | Set whether to make the subscription shared. The shared
subscription name to be used can be specified through the subscriptionName property. Default
is false. Set this to true to register a shared subscription typically in combination with
a subscriptionName value (unless your message listener class name is good enough as subscription
name). Note that shared subscriptions may also be durable so this flag can (and often will)
be combined with subscripti [...]
 | *subscriptionName* (consumer) | Set the name of a subscription to create. To be applied
in case of a topic (pub-sub domain) with a shared or durable subscription. The subscription
name needs to be unique within this client's JMS client id. Default is the class name of the
specified message listener. Note: Only 1 concurrent consumer (which is the default of this
message listener container) is allowed for each subscription except for a shared subscription
(which requires JMS 2.0). |  | String
+| *streamMessageType Enabled* (producer) | Sets whether StreamMessage type is enabled or
not. Message payloads of streaming kind such as files InputStream etc will either by sent
as BytesMessage or StreamMessage. This option controls which kind will be used. By default
BytesMessage is used which enforces the entire message payload to be read into memory. By
enabling this option the message payload is read into memory in chunks and each chunk is then
written to the StreamMessage until no  [...]
 | *headerFilterStrategy* (filter) | To use a custom org.apache.camel.spi.HeaderFilterStrategy
to filter header to and from Camel message. |  | HeaderFilterStrategy
 | *resolveProperty Placeholders* (advanced) | Whether the component should resolve property
placeholders on itself when starting. Only properties which are of String type can use property
placeholders. | true | boolean
 |===
@@ -150,7 +151,7 @@ with the following path and query parameters:
 | *destinationName* | *Required* Name of the queue or topic to use as destination |  | String
 |===
 
-==== Query Parameters (89 parameters):
+==== Query Parameters (90 parameters):
 
 [width="100%",cols="2,5,^1,2",options="header"]
 |===
@@ -206,6 +207,7 @@ with the following path and query parameters:
 | *includeSentJMSMessageID* (producer) | Only applicable when sending to JMS destination
using InOnly (eg fire and forget). Enabling this option will enrich the Camel Exchange with
the actual JMSMessageID that was used by the JMS client when the message was sent to the JMS
destination. | false | boolean
 | *replyToCacheLevelName* (producer) | Sets the cache level by name for the reply consumer
when doing request/reply over JMS. This option only applies when using fixed reply queues
(not temporary). Camel will by default use: CACHE_CONSUMER for exclusive or shared w/ replyToSelectorName.
And CACHE_SESSION for shared without replyToSelectorName. Some JMS brokers such as IBM WebSphere
may require to set the replyToCacheLevelName=CACHE_NONE to work. Note: If using temporary
queues then CACHE [...]
 | *replyToDestinationSelector Name* (producer) | 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). |  | String
+| *streamMessageTypeEnabled* (producer) | Sets whether StreamMessage type is enabled or not.
Message payloads of streaming kind such as files InputStream etc will either by sent as BytesMessage
or StreamMessage. This option controls which kind will be used. By default BytesMessage is
used which enforces the entire message payload to be read into memory. By enabling this option
the message payload is read into memory in chunks and each chunk is then written to the StreamMessage
until no m [...]
 | *allowSerializedHeaders* (advanced) | Controls whether or not to include serialized headers.
Applies only when transferExchange is true. This requires that the objects are serializable.
Camel will exclude any non-serializable objects and log it at WARN level. | false | boolean
 | *asyncStartListener* (advanced) | 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 bew [...]
 | *asyncStopListener* (advanced) | Whether to stop the JmsConsumer message listener asynchronously
when stopping a route. | false | boolean
diff --git a/platforms/spring-boot/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
b/platforms/spring-boot/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
index 5c85fc1..179b37f 100644
--- a/platforms/spring-boot/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
@@ -597,6 +597,16 @@ public class AMQPComponentConfiguration
      */
     private String subscriptionName;
     /**
+     * Sets whether StreamMessage type is enabled or not. Message payloads of
+     * streaming kind such as files InputStream etc will either by sent as
+     * BytesMessage or StreamMessage. This option controls which kind will be
+     * used. By default BytesMessage is used which enforces the entire message
+     * payload to be read into memory. By enabling this option the message
+     * payload is read into memory in chunks and each chunk is then written to
+     * the StreamMessage until no more data.
+     */
+    private Boolean streamMessageTypeEnabled = false;
+    /**
      * To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter
      * header to and from Camel message.
      */
@@ -1230,6 +1240,14 @@ public class AMQPComponentConfiguration
         this.subscriptionName = subscriptionName;
     }
 
+    public Boolean getStreamMessageTypeEnabled() {
+        return streamMessageTypeEnabled;
+    }
+
+    public void setStreamMessageTypeEnabled(Boolean streamMessageTypeEnabled) {
+        this.streamMessageTypeEnabled = streamMessageTypeEnabled;
+    }
+
     public HeaderFilterStrategy getHeaderFilterStrategy() {
         return headerFilterStrategy;
     }

-- 
To stop receiving notification emails like this one, please contact
"commits@camel.apache.org" <commits@camel.apache.org>.

Mime
View raw message