You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/03/13 18:36:23 UTC
[2/3] camel git commit: CAMEL-10995: Generate better default values
for spring boot auto configuration on component options.
CAMEL-10995: Generate better default values for spring boot auto configuration on component options.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d4d574fd
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d4d574fd
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d4d574fd
Branch: refs/heads/master
Commit: d4d574fd13456a109b77fb83a15d690157a97672
Parents: 52c0a26
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Mar 13 19:35:52 2017 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Mar 13 19:36:11 2017 +0100
----------------------------------------------------------------------
.../springboot/AvroComponentConfiguration.java | 4 +-
.../springboot/BoxComponentConfiguration.java | 2 +-
.../springboot/CacheComponentConfiguration.java | 14 +--
.../DigitalSignatureComponentConfiguration.java | 4 +-
.../DockerComponentConfiguration.java | 16 ++--
.../FacebookComponentConfiguration.java | 26 +++---
.../GangliaComponentConfiguration.java | 12 +--
.../GoogleCalendarComponentConfiguration.java | 2 +-
.../springboot/JmsComponentConfiguration.java | 94 +++++++++----------
.../springboot/KafkaComponentConfiguration.java | 96 ++++++++++----------
.../KestrelComponentConfiguration.java | 4 +-
.../LinkedInComponentConfiguration.java | 2 +-
.../springboot/MailComponentConfiguration.java | 40 ++++----
.../springboot/Mina2ComponentConfiguration.java | 32 +++----
.../NagiosComponentConfiguration.java | 4 +-
.../NettyHttpComponentConfiguration.java | 24 ++---
.../springboot/NettyComponentConfiguration.java | 62 ++++++-------
.../NettyHttpComponentConfiguration.java | 24 ++---
.../springboot/NettyComponentConfiguration.java | 70 +++++++-------
.../Olingo2ComponentConfiguration.java | 4 +-
.../SalesforceComponentConfiguration.java | 2 +-
.../ServiceNowComponentConfiguration.java | 2 +-
.../springboot/SmppComponentConfiguration.java | 18 ++--
.../springboot/SshComponentConfiguration.java | 6 +-
.../XmlSignatureComponentConfiguration.java | 22 ++---
.../YammerComponentConfiguration.java | 10 +-
.../ZooKeeperComponentConfiguration.java | 14 +--
27 files changed, 305 insertions(+), 305 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-avro-starter/src/main/java/org/apache/camel/component/avro/springboot/AvroComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-avro-starter/src/main/java/org/apache/camel/component/avro/springboot/AvroComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-avro-starter/src/main/java/org/apache/camel/component/avro/springboot/AvroComponentConfiguration.java
index 5616964..ca10519 100644
--- a/platforms/spring-boot/components-starter/camel-avro-starter/src/main/java/org/apache/camel/component/avro/springboot/AvroComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-avro-starter/src/main/java/org/apache/camel/component/avro/springboot/AvroComponentConfiguration.java
@@ -95,12 +95,12 @@ public class AvroComponentConfiguration {
* only with protocol parameter because for protocolClassName protocol
* type will be auto detected
*/
- private Boolean reflectionProtocol;
+ private Boolean reflectionProtocol = false;
/**
* If true, consumer parameter won't be wrapped into array. Will fail if
* protocol specifies more then 1 parameter for the message
*/
- private Boolean singleParameter;
+ private Boolean singleParameter = false;
public String getHost() {
return host;
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-box-starter/src/main/java/org/apache/camel/component/box/springboot/BoxComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-box-starter/src/main/java/org/apache/camel/component/box/springboot/BoxComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-box-starter/src/main/java/org/apache/camel/component/box/springboot/BoxComponentConfiguration.java
index ff84a54..d60ba98 100644
--- a/platforms/spring-boot/components-starter/camel-box-starter/src/main/java/org/apache/camel/component/box/springboot/BoxComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-box-starter/src/main/java/org/apache/camel/component/box/springboot/BoxComponentConfiguration.java
@@ -124,7 +124,7 @@ public class BoxComponentConfiguration {
* @param authenticationTypethe
* authenticationType to set
*/
- private String authenticationType = org.apache.camel.component.box.BoxConfiguration.APP_USER_AUTHENTICATION;
+ private String authenticationType = "APP_USER_AUTHENTICATION";
/**
* Box application client ID
*
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-cache-starter/src/main/java/org/apache/camel/component/cache/springboot/CacheComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-cache-starter/src/main/java/org/apache/camel/component/cache/springboot/CacheComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-cache-starter/src/main/java/org/apache/camel/component/cache/springboot/CacheComponentConfiguration.java
index 178d310..1872e64 100644
--- a/platforms/spring-boot/components-starter/camel-cache-starter/src/main/java/org/apache/camel/component/cache/springboot/CacheComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-cache-starter/src/main/java/org/apache/camel/component/cache/springboot/CacheComponentConfiguration.java
@@ -98,7 +98,7 @@ public class CacheComponentConfiguration {
* The number of elements that may be stored in the defined cache in
* memory.
*/
- private Integer maxElementsInMemory;
+ private Integer maxElementsInMemory = 1000;
/**
* Which eviction strategy to use when maximum number of elements in
* memory is reached. The strategy defines which elements to be removed.
@@ -113,7 +113,7 @@ public class CacheComponentConfiguration {
/**
* Specifies whether cache may overflow to disk
*/
- private Boolean overflowToDisk;
+ private Boolean overflowToDisk = true;
/**
* This parameter is ignored. CacheManager sets it using setter
* injection.
@@ -124,20 +124,20 @@ public class CacheComponentConfiguration {
* Sets whether elements are eternal. If eternal, timeouts are ignored
* and the element never expires.
*/
- private Boolean eternal;
+ private Boolean eternal = false;
/**
* The maximum time between creation time and when an element expires.
* Is used only if the element is not eternal
*/
- private Long timeToLiveSeconds;
+ private Long timeToLiveSeconds = 300L;
/**
* The maximum amount of time between accesses before an element expires
*/
- private Long timeToIdleSeconds;
+ private Long timeToIdleSeconds = 300L;
/**
* Whether the disk store persists between restarts of the application.
*/
- private Boolean diskPersistent;
+ private Boolean diskPersistent = false;
/**
* The number of seconds between runs of the disk expiry thread.
*/
@@ -157,7 +157,7 @@ public class CacheComponentConfiguration {
* cache. If this option is enabled then overflow to disk cannot be
* enabled as well.
*/
- private Boolean objectCache;
+ private Boolean objectCache = false;
public String getCacheName() {
return cacheName;
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-crypto-starter/src/main/java/org/apache/camel/component/crypto/springboot/DigitalSignatureComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-crypto-starter/src/main/java/org/apache/camel/component/crypto/springboot/DigitalSignatureComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-crypto-starter/src/main/java/org/apache/camel/component/crypto/springboot/DigitalSignatureComponentConfiguration.java
index 8b2bee3..34a0e4c 100644
--- a/platforms/spring-boot/components-starter/camel-crypto-starter/src/main/java/org/apache/camel/component/crypto/springboot/DigitalSignatureComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-crypto-starter/src/main/java/org/apache/camel/component/crypto/springboot/DigitalSignatureComponentConfiguration.java
@@ -162,7 +162,7 @@ public class DigitalSignatureComponentConfiguration {
/**
* Set the size of the buffer used to read in the Exchange payload data.
*/
- private Integer bufferSize;
+ private Integer bufferSize = 2048;
/**
* Set the id of the security provider that provides the configured
* {@link Signature} algorithm.
@@ -182,7 +182,7 @@ public class DigitalSignatureComponentConfiguration {
* at your extreme peril as vital private information such as Keys and
* passwords may escape if unset.
*/
- private Boolean clearHeaders;
+ private Boolean clearHeaders = true;
private CryptoOperation cryptoOperation;
public CamelContext getCamelContext() {
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-docker-starter/src/main/java/org/apache/camel/component/docker/springboot/DockerComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-docker-starter/src/main/java/org/apache/camel/component/docker/springboot/DockerComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-docker-starter/src/main/java/org/apache/camel/component/docker/springboot/DockerComponentConfiguration.java
index bc8c6eb..b788091 100644
--- a/platforms/spring-boot/components-starter/camel-docker-starter/src/main/java/org/apache/camel/component/docker/springboot/DockerComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-docker-starter/src/main/java/org/apache/camel/component/docker/springboot/DockerComponentConfiguration.java
@@ -66,7 +66,7 @@ public class DockerComponentConfiguration {
/**
* Docker port
*/
- private Integer port;
+ private Integer port = 2375;
/**
* User name to authenticate with
*/
@@ -90,7 +90,7 @@ public class DockerComponentConfiguration {
/**
* Use HTTPS communication
*/
- private Boolean secure;
+ private Boolean secure = false;
/**
* Location containing the SSL certificate chain
*/
@@ -98,19 +98,19 @@ public class DockerComponentConfiguration {
/**
* Maximum total connections
*/
- private Integer maxTotalConnections;
+ private Integer maxTotalConnections = 100;
/**
* Maximum route connections
*/
- private Integer maxPerRouteConnections;
+ private Integer maxPerRouteConnections = 100;
/**
* Whether to use logging filter
*/
- private Boolean loggingFilter;
+ private Boolean loggingFilter = false;
/**
* Whether to follow redirect filter
*/
- private Boolean followRedirectFilter;
+ private Boolean followRedirectFilter = false;
/**
* Additional configuration parameters as key/value pairs
*/
@@ -122,11 +122,11 @@ public class DockerComponentConfiguration {
/**
* Check TLS
*/
- private Boolean tlsVerify;
+ private Boolean tlsVerify = false;
/**
* Socket connection mode
*/
- private Boolean socket;
+ private Boolean socket = true;
/**
* The fully qualified class name of the DockerCmdExecFactory
* implementation to use
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-facebook-starter/src/main/java/org/apache/camel/component/facebook/springboot/FacebookComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-facebook-starter/src/main/java/org/apache/camel/component/facebook/springboot/FacebookComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-facebook-starter/src/main/java/org/apache/camel/component/facebook/springboot/FacebookComponentConfiguration.java
index 1698d3e..28b2963 100644
--- a/platforms/spring-boot/components-starter/camel-facebook-starter/src/main/java/org/apache/camel/component/facebook/springboot/FacebookComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-facebook-starter/src/main/java/org/apache/camel/component/facebook/springboot/FacebookComponentConfiguration.java
@@ -89,23 +89,23 @@ public class FacebookComponentConfiguration {
/**
* Enables deubg output. Effective only with the embedded logger
*/
- private Boolean debugEnabled;
+ private Boolean debugEnabled = false;
/**
* Use Facebook GZIP encoding
*/
- private Boolean gzipEnabled;
+ private Boolean gzipEnabled = true;
/**
* Http connection timeout in milliseconds
*/
- private Integer httpConnectionTimeout;
+ private Integer httpConnectionTimeout = 20000;
/**
* HTTP maximum connections per route
*/
- private Integer httpDefaultMaxPerRoute;
+ private Integer httpDefaultMaxPerRoute = 2;
/**
* HTTP maximum total connections
*/
- private Integer httpMaxTotalConnections;
+ private Integer httpMaxTotalConnections = 20;
/**
* HTTP proxy server host name
*/
@@ -125,27 +125,27 @@ public class FacebookComponentConfiguration {
/**
* Http read timeout in milliseconds
*/
- private Integer httpReadTimeout;
+ private Integer httpReadTimeout = 120000;
/**
* Number of HTTP retries
*/
- private Integer httpRetryCount;
+ private Integer httpRetryCount = 0;
/**
* HTTP retry interval in seconds
*/
- private Integer httpRetryIntervalSeconds;
+ private Integer httpRetryIntervalSeconds = 5;
/**
* HTTP streaming read timeout in milliseconds
*/
- private Integer httpStreamingReadTimeout;
+ private Integer httpStreamingReadTimeout = 40000;
/**
* If set to true, raw JSON forms will be stored in DataObjectFactory
*/
- private Boolean jsonStoreEnabled;
+ private Boolean jsonStoreEnabled = false;
/**
* If set to true, Facebook4J mbean will be registerd
*/
- private Boolean mbeanEnabled;
+ private Boolean mbeanEnabled = false;
/**
* Default OAuth permissions. Comma separated permission names. See
* https://developers.facebook.com/docs/reference/login/#permissions for
@@ -155,7 +155,7 @@ public class FacebookComponentConfiguration {
/**
* Prettify JSON debug output if set to true
*/
- private Boolean prettyDebugEnabled;
+ private Boolean prettyDebugEnabled = false;
/**
* API base URL
*/
@@ -163,7 +163,7 @@ public class FacebookComponentConfiguration {
/**
* Use SSL
*/
- private Boolean useSSL;
+ private Boolean useSSL = true;
/**
* Video API base URL
*/
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-ganglia-starter/src/main/java/org/apache/camel/component/ganglia/springboot/GangliaComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-ganglia-starter/src/main/java/org/apache/camel/component/ganglia/springboot/GangliaComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-ganglia-starter/src/main/java/org/apache/camel/component/ganglia/springboot/GangliaComponentConfiguration.java
index e0b7b65..7763525 100644
--- a/platforms/spring-boot/components-starter/camel-ganglia-starter/src/main/java/org/apache/camel/component/ganglia/springboot/GangliaComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-ganglia-starter/src/main/java/org/apache/camel/component/ganglia/springboot/GangliaComponentConfiguration.java
@@ -65,11 +65,11 @@ public class GangliaComponentConfiguration {
/**
* Host name for Ganglia server
*/
- private String host = org.apache.camel.component.ganglia.GangliaConfiguration.DEFAULT_DESTINATION;
+ private String host = "239.2.11.71";
/**
* Port for Ganglia server
*/
- private Integer port;
+ private Integer port = 8649;
/**
* Send the UDP metric packets using MULTICAST or UNICAST
*/
@@ -77,12 +77,12 @@ public class GangliaComponentConfiguration {
/**
* If using multicast, set the TTL of the packets
*/
- private Integer ttl;
+ private Integer ttl = 5;
/**
* Use the wire format of Ganglia 3.1.0 and later versions. Set this to
* false to use Ganglia 3.0.x or earlier.
*/
- private Boolean wireFormat31x;
+ private Boolean wireFormat31x = true;
/**
* Spoofing information IP:hostname
*/
@@ -117,13 +117,13 @@ public class GangliaComponentConfiguration {
* Maximum time in seconds that the value can be considered current.
* After this, Ganglia considers the value to have expired.
*/
- private Integer tmax;
+ private Integer tmax = 60;
/**
* Minumum time in seconds before Ganglia will purge the metric value if
* it expires. Set to 0 and the value will remain in Ganglia
* indefinitely until a gmond agent restart.
*/
- private Integer dmax;
+ private Integer dmax = 0;
public String getHost() {
return host;
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-google-calendar-starter/src/main/java/org/apache/camel/component/google/calendar/springboot/GoogleCalendarComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-google-calendar-starter/src/main/java/org/apache/camel/component/google/calendar/springboot/GoogleCalendarComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-google-calendar-starter/src/main/java/org/apache/camel/component/google/calendar/springboot/GoogleCalendarComponentConfiguration.java
index 53de646..68c5683 100644
--- a/platforms/spring-boot/components-starter/camel-google-calendar-starter/src/main/java/org/apache/camel/component/google/calendar/springboot/GoogleCalendarComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-google-calendar-starter/src/main/java/org/apache/camel/component/google/calendar/springboot/GoogleCalendarComponentConfiguration.java
@@ -116,7 +116,7 @@ public class GoogleCalendarComponentConfiguration {
* See https://developers.google.com/google-apps/calendar/auth for more
* info.
*/
- private String scopes = com.google.api.services.calendar.CalendarScopes.CALENDAR;
+ private String scopes = "https://www.googleapis.com/auth/calendar";
/**
* The name of the p12 file which has the private key to use with the
* Google Service Account.
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
index 1f50c64..bfa2433 100644
--- a/platforms/spring-boot/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
@@ -1248,7 +1248,7 @@ public class JmsComponentConfiguration {
/**
* Specifies whether the consumer container should auto-startup.
*/
- private Boolean autoStartup;
+ private Boolean autoStartup = true;
/**
* Specifies whether the consumer accept messages while it is stopping.
* You may consider enabling this option, if you start and stop JMS
@@ -1259,8 +1259,8 @@ public class JmsComponentConfiguration {
* message may be moved at a dead letter queue on the JMS broker. To
* avoid this its recommended to enable this option.
*/
- private Boolean acceptMessagesWhileStopping;
- private Boolean allowReplyManagerQuickStop;
+ private Boolean acceptMessagesWhileStopping = false;
+ private Boolean allowReplyManagerQuickStop = false;
/**
* 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
@@ -1300,7 +1300,7 @@ public class JmsComponentConfiguration {
* Allows to control whether stacktraces should be logged or not, by the
* default errorHandler.
*/
- private Boolean errorHandlerLogStackTrace;
+ private Boolean errorHandlerLogStackTrace = true;
@Deprecated
private Boolean subscriptionDurable;
/**
@@ -1312,7 +1312,7 @@ public class JmsComponentConfiguration {
* Specifies whether the listener session should be exposed when
* consuming messages.
*/
- private Boolean exposeListenerSession;
+ private Boolean exposeListenerSession = false;
/**
* Allows you to specify a custom task executor for consuming messages.
*/
@@ -1321,7 +1321,7 @@ public class JmsComponentConfiguration {
* Specifies whether to inhibit the delivery of messages published by
* its own connection.
*/
- private Boolean pubSubNoLocal;
+ private Boolean pubSubNoLocal = false;
/**
* Specifies the default number of concurrent consumers when consuming
* from JMS (not for request/reply over JMS). See also the
@@ -1332,20 +1332,20 @@ public class JmsComponentConfiguration {
* replyToConcurrentConsumers is used to control number of concurrent
* consumers on the reply message listener.
*/
- private Integer concurrentConsumers;
+ private Integer concurrentConsumers = 1;
/**
* 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.
*/
- private Integer replyToConcurrentConsumers;
+ private Integer replyToConcurrentConsumers = 1;
/**
* The number of messages per task. -1 is unlimited. If you use a range
* for concurrent consumers (eg min < max), then this option can be used
* to set a value to eg 100 to control how fast the consumers will
* shrink when less work is required.
*/
- private Integer maxMessagesPerTask;
+ private Integer maxMessagesPerTask = -1;
/**
* Sets the cache level by ID for the underlying JMS resources. See
* cacheLevelName option for more details.
@@ -1364,11 +1364,11 @@ public class JmsComponentConfiguration {
* connection is being refreshed, in milliseconds. The default is 5000
* ms, that is, 5 seconds.
*/
- private Long recoveryInterval;
+ private Long recoveryInterval = 5000L;
/**
* The timeout for receiving messages (in milliseconds).
*/
- private Long receiveTimeout;
+ private Long receiveTimeout = 1000L;
/**
* The Spring transaction manager to use.
*/
@@ -1381,7 +1381,7 @@ public class JmsComponentConfiguration {
* The timeout value of the transaction (in seconds), if using
* transacted mode.
*/
- private Integer transactionTimeout;
+ private Integer transactionTimeout = -1;
/**
* Specifies the limit for idle executions of a receive task, not having
* received any message within its execution. If this limit is reached,
@@ -1389,23 +1389,23 @@ public class JmsComponentConfiguration {
* (in the case of dynamic scheduling; see the maxConcurrentConsumers
* setting). There is additional doc available from Spring.
*/
- private Integer idleTaskExecutionLimit;
+ private Integer idleTaskExecutionLimit = 1;
/**
* Specify the limit for the number of consumers that are allowed to be
* idle at any given time.
*/
- private Integer idleConsumerLimit;
+ private Integer idleConsumerLimit = 1;
/**
* 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.
*/
- private Integer waitForProvisionCorrelationToBeUpdatedCounter;
+ private Integer waitForProvisionCorrelationToBeUpdatedCounter = 50;
/**
* Interval in millis to sleep each time while waiting for provisional
* correlation id to be updated.
*/
- private Long waitForProvisionCorrelationToBeUpdatedThreadSleepingTime;
+ private Long waitForProvisionCorrelationToBeUpdatedThreadSleepingTime = 100L;
/**
* Specifies the maximum number of concurrent consumers when consuming
* from JMS (not for request/reply over JMS). See also the
@@ -1427,11 +1427,11 @@ public class JmsComponentConfiguration {
* Specifies the maximum number of concurrent consumers for continue
* routing when timeout occurred when using request/reply over JMS.
*/
- private Integer replyToOnTimeoutMaxConcurrentConsumers;
+ private Integer replyToOnTimeoutMaxConcurrentConsumers = 1;
/**
* Specifies whether persistent delivery is used by default.
*/
- private Boolean deliveryPersistent;
+ private Boolean deliveryPersistent = true;
/**
* Specifies the delivery mode to be used. Possibles values are those
* defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT
@@ -1441,12 +1441,12 @@ public class JmsComponentConfiguration {
/**
* Specifies whether to use persistent delivery by default for replies.
*/
- private Boolean replyToDeliveryPersistent;
+ private Boolean replyToDeliveryPersistent = true;
/**
* When sending messages, specifies the time-to-live of the message (in
* milliseconds).
*/
- private Long timeToLive;
+ private Long timeToLive = -1L;
/**
* To use a custom Spring
* org.springframework.jms.support.converter.MessageConverter so you can
@@ -1457,7 +1457,7 @@ public class JmsComponentConfiguration {
* Specifies whether Camel should auto map the received JMS message to a
* suited payload type, such as javax.jms.TextMessage to a String etc.
*/
- private Boolean mapJmsMessage;
+ private Boolean mapJmsMessage = true;
/**
* When sending, specifies whether message IDs should be added. This is
* just an hint to the JMS Broker. If the JMS provider accepts this
@@ -1465,7 +1465,7 @@ public class JmsComponentConfiguration {
* provider ignores the hint, the message ID must be set to its normal
* unique value
*/
- private Boolean messageIdEnabled;
+ private Boolean messageIdEnabled = true;
/**
* Specifies whether timestamps should be enabled by default on sending
* messages. This is just an hint to the JMS Broker. If the JMS provider
@@ -1473,14 +1473,14 @@ public class JmsComponentConfiguration {
* zero; if the provider ignores the hint, the timestamp must be set to
* its normal value
*/
- private Boolean messageTimestampEnabled;
+ private Boolean messageTimestampEnabled = true;
/**
* Values greater than 1 specify the message priority when sending
* (where 0 is the lowest priority and 9 is the highest). The
* explicitQosEnabled option must also be enabled in order for this
* option to have any effect.
*/
- private Integer priority;
+ private Integer priority = 4;
/**
* The JMS acknowledgement mode defined as an Integer. Allows you to set
* vendor-specific extensions to the acknowledgment mode. For the
@@ -1491,21 +1491,21 @@ public class JmsComponentConfiguration {
/**
* Specifies whether to use transacted mode
*/
- private Boolean transacted;
+ private Boolean transacted = false;
@Deprecated
private Boolean transactedInOut;
/**
* If true, Camel will create a JmsTransactionManager, if there is no
* transactionManager injected when option transacted=true.
*/
- private Boolean lazyCreateTransactionManager;
+ private Boolean lazyCreateTransactionManager = true;
/**
* Enables eager loading of JMS properties as soon as a message is
* loaded which generally is inefficient as the JMS properties may not
* be required but sometimes can catch early any issues with the
* underlying JMS provider and the use of JMS properties
*/
- private Boolean eagerLoadingOfProperties;
+ private Boolean eagerLoadingOfProperties = false;
/**
* If true, a producer will behave like a InOnly exchange with the
* exception that JMSReplyTo header is sent out and not be suppressed
@@ -1515,7 +1515,7 @@ public class JmsComponentConfiguration {
* a route on the other queue will send its response directly back to
* the original JMSReplyTo.
*/
- private Boolean disableReplyTo;
+ private Boolean disableReplyTo = false;
/**
* Set to true, if you want to send message using the QoS settings
* specified on the message, instead of the QoS settings on the JMS
@@ -1527,7 +1527,7 @@ public class JmsComponentConfiguration {
* by contrast, will only use options set on the endpoint, and not
* values from the message header.
*/
- private Boolean preserveMessageQos;
+ private Boolean preserveMessageQos = false;
/**
* Allows you to use your own implementation of the
* org.springframework.jms.core.JmsOperations interface. Camel uses
@@ -1563,12 +1563,12 @@ public class JmsComponentConfiguration {
* the alwaysCopyMessage option to true, if a
* replyToDestinationSelectorName is set)
*/
- private Boolean alwaysCopyMessage;
+ private Boolean alwaysCopyMessage = false;
/**
* Specifies whether JMSMessageID should always be used as
* JMSCorrelationID for InOut messages.
*/
- private Boolean useMessageIDAsCorrelationID;
+ private Boolean useMessageIDAsCorrelationID = false;
/**
* The timeout for waiting for a reply when using the InOut Exchange
* Pattern (in milliseconds). The default is 20 seconds. You can include
@@ -1576,7 +1576,7 @@ public class JmsComponentConfiguration {
* configured timeout value, and thus have per message individual
* timeout values. See also the requestTimeoutCheckerInterval option.
*/
- private Long requestTimeout;
+ private Long requestTimeout = 20000L;
/**
* Configures how often Camel should check for timed out Exchanges when
* doing request/reply over JMS. By default Camel checks once per
@@ -1584,7 +1584,7 @@ public class JmsComponentConfiguration {
* can lower this interval, to check more frequently. The timeout is
* determined by the option requestTimeout.
*/
- private Long requestTimeoutCheckerInterval;
+ private Long requestTimeoutCheckerInterval = 1000L;
/**
* Provides an explicit ReplyTo destination, which overrides any
* incoming value of Message.getJMSReplyTo().
@@ -1609,7 +1609,7 @@ public class JmsComponentConfiguration {
* an endless loop by consuming and sending back the same message to
* itself.
*/
- private Boolean replyToSameDestinationAllowed;
+ private Boolean replyToSameDestinationAllowed = false;
/**
* Allows you to force the use of a specific javax.jms.Message
* implementation for sending JMS messages. Possible values are: Bytes,
@@ -1640,14 +1640,14 @@ public class JmsComponentConfiguration {
* and consumer side, so Camel knows the payloads is an Exchange and not
* a regular payload.
*/
- private Boolean transferExchange;
+ private Boolean transferExchange = false;
/**
* Controls whether or not to include serialized headers. Applies only
* when {@link #isTransferExchange()} is {@code true} . This requires
* that the objects are serializable. Camel will exclude any
* non-serializable objects and log it at WARN level.
*/
- private Boolean allowSerializedHeaders;
+ private Boolean allowSerializedHeaders = false;
/**
* If enabled and you are using Request Reply messaging (InOut) and an
* Exchange failed on the consumer side, then the caused Exception will
@@ -1660,7 +1660,7 @@ public class JmsComponentConfiguration {
* the consumer side can be wrapped in an outer exception such as
* org.apache.camel.RuntimeCamelException when returned to the producer.
*/
- private Boolean transferException;
+ private Boolean transferException = false;
/**
* If enabled and you are using Request Reply messaging (InOut) and an
* Exchange failed with a SOAP fault (not exception) on the consumer
@@ -1674,7 +1674,7 @@ public class JmsComponentConfiguration {
* You may want to enable this when using Camel components that support
* faults such as SOAP based such as cxf or spring-ws.
*/
- private Boolean transferFault;
+ private Boolean transferFault = false;
/**
* Whether to startup the JmsConsumer message listener asynchronously,
* when starting a route. For example if a JmsConsumer cannot get a
@@ -1687,12 +1687,12 @@ public class JmsComponentConfiguration {
* logged at WARN level, and the consumer will not be able to receive
* messages; You can then restart the route to retry.
*/
- private Boolean asyncStartListener;
+ private Boolean asyncStartListener = false;
/**
* Whether to stop the JmsConsumer message listener asynchronously, when
* stopping a route.
*/
- private Boolean asyncStopListener;
+ private Boolean asyncStopListener = false;
/**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
@@ -1700,14 +1700,14 @@ public class JmsComponentConfiguration {
* Camel throws an exception on startup. This ensures that Camel is not
* started with failed connections. The JMS producers is tested as well.
*/
- private Boolean testConnectionOnStartup;
+ private Boolean testConnectionOnStartup = false;
/**
* When using mapJmsMessage=false Camel will create a new JMS message to
* send to a new JMS destination if you touch the headers (get or set)
* during the route. Set this option to true to force Camel to send the
* original JMS message that was received.
*/
- private Boolean forceSendOriginalMessage;
+ private Boolean forceSendOriginalMessage = false;
/**
* Use this option to force disabling time to live. For example when you
* do request/reply over JMS, then Camel will by default use the
@@ -1719,7 +1719,7 @@ public class JmsComponentConfiguration {
* on the receiver system. See below in section About time to live for
* more details.
*/
- private Boolean disableTimeToLive;
+ private Boolean disableTimeToLive = false;
/**
* Allows for explicitly specifying which kind of strategy to use for
* replyTo queues when doing request/reply over JMS. Possible values
@@ -1744,7 +1744,7 @@ public class JmsComponentConfiguration {
* transaction must be executed synchronously (Camel 3.0 may support
* async transactions).
*/
- private Boolean asyncConsumer;
+ private Boolean asyncConsumer = false;
/**
* Sets the cache level by name for the reply consumer when doing
* request/reply over JMS. This option only applies when using fixed
@@ -1761,7 +1761,7 @@ public class JmsComponentConfiguration {
* Whether to allow sending messages with no body. If this option is
* false and the message body is null, then an JMSException is thrown.
*/
- private Boolean allowNullBody;
+ private Boolean allowNullBody = true;
/**
* Registry ID of the MessageListenerContainerFactory used to determine
* what
@@ -1776,7 +1776,7 @@ public class JmsComponentConfiguration {
* the actual JMSMessageID that was used by the JMS client when the
* message was sent to the JMS destination.
*/
- private Boolean includeSentJMSMessageID;
+ private Boolean includeSentJMSMessageID = false;
/**
* Specifies what default TaskExecutor type to use in the
* DefaultMessageListenerContainer, for both consumer endpoints and the
@@ -1796,7 +1796,7 @@ public class JmsComponentConfiguration {
* JMSXAppID, and JMSXUserID etc. Note: If you are using a custom
* headerFilterStrategy then this option does not apply.
*/
- private Boolean includeAllJMSXProperties;
+ private Boolean includeAllJMSXProperties = false;
/**
* To use the given MessageCreatedStrategy which are invoked when Camel
* creates new instances of <tt>javax.jms.Message</tt> objects when
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
index 93b3cda..09c5211 100644
--- a/platforms/spring-boot/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-kafka-starter/src/main/java/org/apache/camel/component/kafka/springboot/KafkaComponentConfiguration.java
@@ -105,7 +105,7 @@ public class KafkaComponentConfiguration {
* The partitioner class for partitioning messages amongst sub-topics.
* The default partitioner is based on the hash of the key.
*/
- private String partitioner = org.apache.camel.component.kafka.KafkaConstants.KAFKA_DEFAULT_PARTITIONER;
+ private String partitioner = "org.apache.kafka.clients.producer.internals.DefaultPartitioner";
/**
* Name of the topic to use. On the consumer you can use comma to
* separate multiple topics. A producer can only send a message to a
@@ -115,11 +115,11 @@ public class KafkaComponentConfiguration {
/**
* Number of concurrent consumers on the consumer
*/
- private Integer consumerStreams;
+ private Integer consumerStreams = 10;
/**
* The number of consumers that connect to kafka server
*/
- private Integer consumersCount;
+ private Integer consumersCount = 1;
/**
* The client id is a user-specified string sent in each request to help
* trace calls. It should logically identify the application making the
@@ -132,7 +132,7 @@ public class KafkaComponentConfiguration {
* when the process fails as the position from which the new consumer
* will begin.
*/
- private Boolean autoCommitEnable;
+ private Boolean autoCommitEnable = true;
/**
* The offset repository to use in order to locally store the offset of
* each partition of the topic. Defining one will disable the
@@ -143,20 +143,20 @@ public class KafkaComponentConfiguration {
* The frequency in ms that the consumer offsets are committed to
* zookeeper.
*/
- private Integer autoCommitIntervalMs;
+ private Integer autoCommitIntervalMs = 5000;
/**
* The minimum amount of data the server should return for a fetch
* request. If insufficient data is available the request will wait for
* that much data to accumulate before answering the request.
*/
- private Integer fetchMinBytes;
- private Integer fetchMaxBytes;
+ private Integer fetchMinBytes = 1;
+ private Integer fetchMaxBytes = 52428800;
/**
* The maximum amount of time the server will block before answering the
* fetch request if there isn't sufficient data to immediately satisfy
* fetch.min.bytes
*/
- private Integer fetchWaitMaxMs;
+ private Integer fetchWaitMaxMs = 500;
/**
* What to do when there is no initial offset in ZooKeeper or if an
* offset is out of range: smallest : automatically reset the offset to
@@ -192,40 +192,40 @@ public class KafkaComponentConfiguration {
* takes a bit of time, this property specifies the amount of time that
* the producer waits before refreshing the metadata.
*/
- private Integer retryBackoffMs;
+ private Integer retryBackoffMs = 100;
/**
* Socket write buffer size
*/
- private Integer sendBufferBytes;
+ private Integer sendBufferBytes = 131072;
/**
* The amount of time the broker will wait trying to meet the
* request.required.acks requirement before sending back an error to the
* client.
*/
- private Integer requestTimeoutMs;
+ private Integer requestTimeoutMs = 305000;
/**
* The maximum number of unsent messages that can be queued up the
* producer when using async mode before either the producer must be
* blocked or data must be dropped.
*/
- private Integer queueBufferingMaxMessages;
+ private Integer queueBufferingMaxMessages = 10000;
/**
* The serializer class for messages.
*/
- private String serializerClass = org.apache.camel.component.kafka.KafkaConstants.KAFKA_DEFAULT_SERIALIZER;
+ private String serializerClass = "org.apache.kafka.common.serialization.StringSerializer";
/**
* The serializer class for keys (defaults to the same as for messages
* if nothing is given).
*/
- private String keySerializerClass = org.apache.camel.component.kafka.KafkaConstants.KAFKA_DEFAULT_SERIALIZER;
+ private String keySerializerClass = "org.apache.kafka.common.serialization.StringSerializer";
/**
* Kerberos kinit command path. Default is /usr/bin/kinit
*/
- private String kerberosInitCmd = org.apache.kafka.common.config.SaslConfigs.DEFAULT_KERBEROS_KINIT_CMD;
+ private String kerberosInitCmd = "/usr/bin/kinit";
/**
* Login thread sleep time between refresh attempts.
*/
- private Integer kerberosBeforeReloginMinTime;
+ private Integer kerberosBeforeReloginMinTime = 60000;
/**
* Percentage of random jitter added to the renewal time.
*/
@@ -277,12 +277,12 @@ public class KafkaComponentConfiguration {
* The list of protocols enabled for SSL connections. TLSv1.2, TLSv1.1
* and TLSv1 are enabled by default.
*/
- private String sslEnabledProtocols = org.apache.kafka.common.config.SslConfigs.DEFAULT_SSL_ENABLED_PROTOCOLS;
+ private String sslEnabledProtocols = "TLSv1.2,TLSv1.1,TLSv1";
/**
* The file format of the key store file. This is optional for client.
* Default value is JKS
*/
- private String sslKeystoreType = org.apache.kafka.common.config.SslConfigs.DEFAULT_SSL_KEYSTORE_TYPE;
+ private String sslKeystoreType = "JKS";
/**
* The SSL protocol used to generate the SSLContext. Default setting is
* TLS, which is fine for most cases. Allowed values in recent JVMs are
@@ -290,7 +290,7 @@ public class KafkaComponentConfiguration {
* older JVMs, but their usage is discouraged due to known security
* vulnerabilities.
*/
- private String sslProtocol = org.apache.kafka.common.config.SslConfigs.DEFAULT_SSL_PROTOCOL;
+ private String sslProtocol = "TLS";
/**
* The name of the security provider used for SSL connections. Default
* value is the default security provider of the JVM.
@@ -299,7 +299,7 @@ public class KafkaComponentConfiguration {
/**
* The file format of the trust store file. Default value is JKS.
*/
- private String sslTruststoreType = org.apache.kafka.common.config.SslConfigs.DEFAULT_SSL_TRUSTSTORE_TYPE;
+ private String sslTruststoreType = "JKS";
/**
* The Kerberos principal name that Kafka runs as. This can be defined
* either in Kafka's JAAS config or in Kafka's config.
@@ -312,12 +312,12 @@ public class KafkaComponentConfiguration {
* >http://www.iana.org/assignments/sasl-mechanisms/sasl-mechanisms.
* xhtml</a>
*/
- private String saslMechanism = org.apache.kafka.common.config.SaslConfigs.DEFAULT_SASL_MECHANISM;
+ private String saslMechanism = "GSSAPI";
/**
* Protocol used to communicate with brokers. Currently only PLAINTEXT
* and SSL are supported.
*/
- private String securityProtocol = org.apache.kafka.clients.CommonClientConfigs.DEFAULT_SECURITY_PROTOCOL;
+ private String securityProtocol = "PLAINTEXT";
/**
* SSL configuration using a Camel {@link SSLContextParameters} object.
* If configured it's applied before the other SSL endpoint parameters.
@@ -358,7 +358,7 @@ public class KafkaComponentConfiguration {
* memory will be used for compression (if compression is enabled) as
* well as for maintaining in-flight requests.
*/
- private Integer bufferMemorySize;
+ private Integer bufferMemorySize = 33554432;
/**
* The record key (or null if no key is specified). If this option has
* been configured then it take precedence over header
@@ -401,7 +401,7 @@ public class KafkaComponentConfiguration {
* partition, and the first fails and is retried but the second
* succeeds, then the second record may appear first.
*/
- private Integer retries;
+ private Integer retries = 0;
/**
* The producer will attempt to batch records together into fewer
* requests whenever multiple records are being sent to the same
@@ -415,12 +415,12 @@ public class KafkaComponentConfiguration {
* bit more wastefully as we will always allocate a buffer of the
* specified batch size in anticipation of additional records.
*/
- private Integer producerBatchSize;
+ private Integer producerBatchSize = 16384;
/**
* Close idle connections after the number of milliseconds specified by
* this config.
*/
- private Integer connectionMaxIdleMs;
+ private Integer connectionMaxIdleMs = 540000;
/**
* The producer groups together any records that arrive in between
* request transmissions into a single batched request. Normally this
@@ -441,7 +441,7 @@ public class KafkaComponentConfiguration {
* effect of reducing the number of requests sent but would add up to
* 5ms of latency to records sent in the absense of load.
*/
- private Integer lingerMs;
+ private Integer lingerMs = 0;
/**
* The configuration controls how long sending to kafka will block.
* These methods can be blocked for multiple reasons. For e.g: buffer
@@ -451,7 +451,7 @@ public class KafkaComponentConfiguration {
* send(). In case of partitionsFor(), this configuration imposes a
* maximum time threshold on waiting for metadata
*/
- private Integer maxBlockMs;
+ private Integer maxBlockMs = 60000;
/**
* The maximum size of a request. This is also effectively a cap on the
* maximum record size. Note that the server has its own cap on record
@@ -459,25 +459,25 @@ public class KafkaComponentConfiguration {
* number of record batches the producer will send in a single request
* to avoid sending huge requests.
*/
- private Integer maxRequestSize;
+ private Integer maxRequestSize = 1048576;
/**
* The size of the TCP receive buffer (SO_RCVBUF) to use when reading
* data.
*/
- private Integer receiveBufferBytes;
+ private Integer receiveBufferBytes = 65536;
/**
* The maximum number of unacknowledged requests the client will send on
* a single connection before blocking. Note that if this setting is set
* to be greater than 1 and there are failed sends, there is a risk of
* message re-ordering due to retries (i.e., if retries are enabled).
*/
- private Integer maxInFlightRequest;
+ private Integer maxInFlightRequest = 5;
/**
* The period of time in milliseconds after which we force a refresh of
* metadata even if we haven't seen any partition leadership changes to
* proactively discover any new brokers or partitions.
*/
- private Integer metadataMaxAgeMs;
+ private Integer metadataMaxAgeMs = 300000;
/**
* A list of classes to use as metrics reporters. Implementing the
* MetricReporter interface allows plugging in classes that will be
@@ -488,18 +488,18 @@ public class KafkaComponentConfiguration {
/**
* The number of samples maintained to compute metrics.
*/
- private Integer noOfMetricsSample;
+ private Integer noOfMetricsSample = 2;
/**
* The number of samples maintained to compute metrics.
*/
- private Integer metricsSampleWindowMs;
+ private Integer metricsSampleWindowMs = 30000;
/**
* The amount of time to wait before attempting to reconnect to a given
* host. This avoids repeatedly connecting to a host in a tight loop.
* This backoff applies to all requests sent by the consumer to the
* broker.
*/
- private Integer reconnectBackoffMs;
+ private Integer reconnectBackoffMs = 50;
/**
* The expected time between heartbeats to the consumer coordinator when
* using Kafka's group management facilities. Heartbeats are used to
@@ -509,7 +509,7 @@ public class KafkaComponentConfiguration {
* set no higher than 1/3 of that value. It can be adjusted even lower
* to control the expected time for normal rebalances.
*/
- private Integer heartbeatIntervalMs;
+ private Integer heartbeatIntervalMs = 3000;
/**
* The maximum amount of data per-partition the server will return. The
* maximum total memory used for a request will be #partitions *
@@ -519,50 +519,50 @@ public class KafkaComponentConfiguration {
* happens, the consumer can get stuck trying to fetch a large message
* on a certain partition.
*/
- private Integer maxPartitionFetchBytes;
+ private Integer maxPartitionFetchBytes = 1048576;
/**
* The timeout used to detect failures when using Kafka's group
* management facilities.
*/
- private Integer sessionTimeoutMs;
+ private Integer sessionTimeoutMs = 10000;
/**
* The maximum number of records returned in a single call to poll()
*/
- private Integer maxPollRecords;
+ private Integer maxPollRecords = 500;
/**
* The timeout used when polling the KafkaConsumer.
*/
- private Long pollTimeoutMs;
+ private Long pollTimeoutMs = 5000L;
/**
* The class name of the partition assignment strategy that the client
* will use to distribute partition ownership amongst consumer instances
* when group management is used
*/
- private String partitionAssignor = org.apache.camel.component.kafka.KafkaConstants.PARTITIONER_RANGE_ASSIGNOR;
+ private String partitionAssignor = "org.apache.kafka.clients.consumer.RangeAssignor";
/**
* The configuration controls the maximum amount of time the client will
* wait for the response of a request. If the response is not received
* before the timeout elapses the client will resend the request if
* necessary or fail the request if retries are exhausted.
*/
- private Integer consumerRequestTimeoutMs;
+ private Integer consumerRequestTimeoutMs = 40000;
/**
* Automatically check the CRC32 of the records consumed. This ensures
* no on-the-wire or on-disk corruption to the messages occurred. This
* check adds some overhead, so it may be disabled in cases seeking
* extreme performance.
*/
- private Boolean checkCrcs;
+ private Boolean checkCrcs = true;
/**
* Deserializer class for key that implements the Deserializer
* interface.
*/
- private String keyDeserializer = org.apache.camel.component.kafka.KafkaConstants.KAFKA_DEFAULT_DESERIALIZER;
+ private String keyDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";
/**
* Deserializer class for value that implements the Deserializer
* interface.
*/
- private String valueDeserializer = org.apache.camel.component.kafka.KafkaConstants.KAFKA_DEFAULT_DESERIALIZER;
+ private String valueDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";
/**
* Set if KafkaConsumer will read from beginning or end on startup:
* beginning : read from beginning end : read from end This is replacing
@@ -582,21 +582,21 @@ public class KafkaComponentConfiguration {
* was sent to it from {@link KafkaProducer} using asynchronous
* non-blocking processing.
*/
- private Integer workerPoolCoreSize;
+ private Integer workerPoolCoreSize = 10;
/**
* Maximum number of threads for the worker pool for continue routing
* {@link Exchange} after kafka server has acknowledge the message that
* was sent to it from {@link KafkaProducer} using asynchronous
* non-blocking processing.
*/
- private Integer workerPoolMaxSize;
+ private Integer workerPoolMaxSize = 20;
/**
* Whether the producer should store the {@link RecordMetadata} results
* from sending to Kafka. The results are stored in a {@link List}
* containing the {@link RecordMetadata} metadata's. The list is stored
* on a header with the key {@link KafkaConstants#KAFKA_RECORDMETA}
*/
- private Boolean recordMetadata;
+ private Boolean recordMetadata = true;
/**
* Sets interceptors for producer or consumers. Producer interceptors
* have to be classes implementing
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-kestrel-starter/src/main/java/org/apache/camel/component/kestrel/springboot/KestrelComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-kestrel-starter/src/main/java/org/apache/camel/component/kestrel/springboot/KestrelComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-kestrel-starter/src/main/java/org/apache/camel/component/kestrel/springboot/KestrelComponentConfiguration.java
index f577514..9d62010 100644
--- a/platforms/spring-boot/components-starter/camel-kestrel-starter/src/main/java/org/apache/camel/component/kestrel/springboot/KestrelComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-kestrel-starter/src/main/java/org/apache/camel/component/kestrel/springboot/KestrelComponentConfiguration.java
@@ -66,11 +66,11 @@ public class KestrelComponentConfiguration {
/**
* The wait time in milliseconds
*/
- private Integer waitTimeMs;
+ private Integer waitTimeMs = 100;
/**
* The number of concurrent consumers
*/
- private Integer concurrentConsumers;
+ private Integer concurrentConsumers = 1;
public String[] getAddresses() {
return addresses;
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-linkedin-starter/src/main/java/org/apache/camel/component/linkedin/springboot/LinkedInComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-linkedin-starter/src/main/java/org/apache/camel/component/linkedin/springboot/LinkedInComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-linkedin-starter/src/main/java/org/apache/camel/component/linkedin/springboot/LinkedInComponentConfiguration.java
index 56c5bbd..86ab776 100644
--- a/platforms/spring-boot/components-starter/camel-linkedin-starter/src/main/java/org/apache/camel/component/linkedin/springboot/LinkedInComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-linkedin-starter/src/main/java/org/apache/camel/component/linkedin/springboot/LinkedInComponentConfiguration.java
@@ -115,7 +115,7 @@ public class LinkedInComponentConfiguration {
* OAuth token retrieval or generation is not done until the first REST
* call
*/
- private Boolean lazyAuth;
+ private Boolean lazyAuth = true;
public LinkedInApiName getApiName() {
return apiName;
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-mail-starter/src/main/java/org/apache/camel/component/mail/springboot/MailComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-mail-starter/src/main/java/org/apache/camel/component/mail/springboot/MailComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-mail-starter/src/main/java/org/apache/camel/component/mail/springboot/MailComponentConfiguration.java
index f2e9bd5..f743ec2 100644
--- a/platforms/spring-boot/components-starter/camel-mail-starter/src/main/java/org/apache/camel/component/mail/springboot/MailComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-mail-starter/src/main/java/org/apache/camel/component/mail/springboot/MailComponentConfiguration.java
@@ -131,7 +131,7 @@ public class MailComponentConfiguration {
/**
* The from email address
*/
- private String from = org.apache.camel.component.mail.MailConstants.MAIL_DEFAULT_FROM;
+ private String from = "camel@localhost";
/**
* Deletes the messages after they have been processed. This is done by
* setting the DELETED flag on the mail message. If false, the SEEN flag
@@ -139,7 +139,7 @@ public class MailComponentConfiguration {
* option by setting a header with the key delete to determine if the
* mail should be deleted or not.
*/
- private Boolean delete;
+ private Boolean delete = false;
/**
* Specifies whether Camel should map the received mail message to Camel
* body/headers. If set to true, the body of the mail message is mapped
@@ -148,22 +148,22 @@ public class MailComponentConfiguration {
* contains a raw javax.mail.Message. You can retrieve this raw message
* by calling exchange.getIn().getBody(javax.mail.Message.class).
*/
- private Boolean mapMailMessage;
+ private Boolean mapMailMessage = true;
/**
* The folder to poll.
*/
- private String folderName = org.apache.camel.component.mail.MailConstants.MAIL_DEFAULT_FOLDER;
+ private String folderName = "INBOX";
/**
* Option to let Camel ignore unsupported charset in the local JVM when
* sending mails. If the charset is unsupported then charset=XXX (where
* XXX represents the unsupported charset) is removed from the
* content-type and it relies on the platform default instead.
*/
- private Boolean ignoreUriScheme;
+ private Boolean ignoreUriScheme = false;
/**
* Whether to limit by unseen mails only.
*/
- private Boolean unseen;
+ private Boolean unseen = true;
/**
* Sets the To email address. Separate multiple email addresses with
* comma.
@@ -192,21 +192,21 @@ public class MailComponentConfiguration {
* special corner case, where Camel will not consume any messages at
* all.
*/
- private Integer fetchSize;
+ private Integer fetchSize = -1;
/**
* Enable debug mode on the underlying mail framework. The SUN Mail
* framework logs the debug messages to System.out by default.
*/
- private Boolean debugMode;
+ private Boolean debugMode = false;
/**
* The connection timeout in milliseconds.
*/
- private Long connectionTimeout;
+ private Integer connectionTimeout = 30000;
/**
* To use a dummy security setting for trusting all certificates. Should
* only be used for development mode, and not production.
*/
- private Boolean dummyTrustManager;
+ private Boolean dummyTrustManager = false;
/**
* The mail message content type. Use text/html for HTML mails.
*/
@@ -218,29 +218,29 @@ public class MailComponentConfiguration {
* email clients, set the alternative mail body with this key as a
* header.
*/
- private String alternativeBodyHeader = org.apache.camel.component.mail.MailConstants.MAIL_ALTERNATIVE_BODY;
+ private String alternativeBodyHeader = "CamelMailAlternativeBody";
/**
* Whether to use disposition inline or attachment.
*/
- private Boolean useInlineAttachments;
+ private Boolean useInlineAttachments = false;
/**
* Option to let Camel ignore unsupported charset in the local JVM when
* sending mails. If the charset is unsupported then charset=XXX (where
* XXX represents the unsupported charset) is removed from the
* content-type and it relies on the platform default instead.
*/
- private Boolean ignoreUnsupportedCharset;
+ private Boolean ignoreUnsupportedCharset = false;
/**
* Whether the consumer should disconnect after polling. If enabled this
* forces Camel to connect on each poll.
*/
- private Boolean disconnect;
+ private Boolean disconnect = false;
/**
* Whether the consumer should close the folder after polling. Setting
* this option to false and having disconnect=false as well, then the
* consumer keep the folder open between polls.
*/
- private Boolean closeFolder;
+ private Boolean closeFolder = true;
/**
* To configure security using SSLContextParameters.
*/
@@ -260,7 +260,7 @@ public class MailComponentConfiguration {
* which allows us to rollback the mail message if there is an error
* processing in Camel.
*/
- private Boolean peek;
+ private Boolean peek = true;
/**
* If the mail consumer cannot retrieve a given mail message, then this
* option allows to skip the message and move on to retrieve the next
@@ -269,7 +269,7 @@ public class MailComponentConfiguration {
* The default behavior would be the consumer throws an exception and no
* mails from the batch would be able to be routed by Camel.
*/
- private Boolean skipFailedMessage;
+ private Boolean skipFailedMessage = false;
/**
* If the mail consumer cannot retrieve a given mail message, then this
* option allows to handle the caused exception by the consumer's error
@@ -279,7 +279,7 @@ public class MailComponentConfiguration {
* The default behavior would be the consumer throws an exception and no
* mails from the batch would be able to be routed by Camel.
*/
- private Boolean handleFailedMessage;
+ private Boolean handleFailedMessage = false;
/**
* To use a custom AttachmentsContentTransferEncodingResolver to resolve
* what content-type-encoding to use for attachments.
@@ -463,11 +463,11 @@ public class MailComponentConfiguration {
this.debugMode = debugMode;
}
- public Long getConnectionTimeout() {
+ public Integer getConnectionTimeout() {
return connectionTimeout;
}
- public void setConnectionTimeout(Long connectionTimeout) {
+ public void setConnectionTimeout(Integer connectionTimeout) {
this.connectionTimeout = connectionTimeout;
}
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-mina2-starter/src/main/java/org/apache/camel/component/mina2/springboot/Mina2ComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-mina2-starter/src/main/java/org/apache/camel/component/mina2/springboot/Mina2ComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-mina2-starter/src/main/java/org/apache/camel/component/mina2/springboot/Mina2ComponentConfiguration.java
index 997189e..386c7cc 100644
--- a/platforms/spring-boot/components-starter/camel-mina2-starter/src/main/java/org/apache/camel/component/mina2/springboot/Mina2ComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-mina2-starter/src/main/java/org/apache/camel/component/mina2/springboot/Mina2ComponentConfiguration.java
@@ -81,13 +81,13 @@ public class Mina2ComponentConfiguration {
/**
* Setting to set endpoint as one-way or request-response.
*/
- private Boolean sync;
+ private Boolean sync = true;
/**
* Only used for TCP. If no codec is specified, you can use this flag to
* indicate a text line based codec; if not specified or the value is
* false, then Object Serialization is assumed over TCP.
*/
- private Boolean textline;
+ private Boolean textline = false;
/**
* Only used for TCP and if textline=true. Sets the text line delimiter
* to use. If none provided, Camel will use DEFAULT. This delimiter is
@@ -109,12 +109,12 @@ public class Mina2ComponentConfiguration {
* response from a remote server. The timeout unit is in milliseconds,
* so 60000 is 60 seconds.
*/
- private Long timeout;
+ private Long timeout = 30000L;
/**
* Sessions can be lazily created to avoid exceptions, if the remote
* server is not up and running when the Camel producer is started.
*/
- private Boolean lazySessionCreation;
+ private Boolean lazySessionCreation = true;
/**
* Only used for TCP. You can transfer the exchange over the wire
* instead of just the body. The following fields are transferred: In
@@ -123,22 +123,22 @@ public class Mina2ComponentConfiguration {
* objects are serializable. Camel will exclude any non-serializable
* objects and log it at WARN level.
*/
- private Boolean transferExchange;
+ private Boolean transferExchange = false;
/**
* To set the textline protocol encoder max line length. By default the
* default value of Mina itself is used which are Integer.MAX_VALUE.
*/
- private Integer encoderMaxLineLength;
+ private Integer encoderMaxLineLength = -1;
/**
* To set the textline protocol decoder max line length. By default the
* default value of Mina itself is used which are 1024.
*/
- private Integer decoderMaxLineLength;
+ private Integer decoderMaxLineLength = 1024;
/**
* You can enable the Apache MINA logging filter. Apache MINA uses slf4j
* logging at INFO level to log all input and output.
*/
- private Boolean minaLogger;
+ private Boolean minaLogger = false;
/**
* You can set a list of Mina IoFilters to use.
*/
@@ -151,17 +151,17 @@ public class Mina2ComponentConfiguration {
* another filter must be the first in the filter chain, like the SSL
* filter.
*/
- private Boolean allowDefaultCodec;
+ private Boolean allowDefaultCodec = true;
/**
* Whether or not to disconnect(close) from Mina session right after
* use. Can be used for both consumer and producer.
*/
- private Boolean disconnect;
+ private Boolean disconnect = false;
/**
* If sync is enabled then this option dictates MinaConsumer if it
* should disconnect where there is no reply to send back.
*/
- private Boolean disconnectOnNoReply;
+ private Boolean disconnectOnNoReply = true;
/**
* If sync is enabled this option dictates MinaConsumer which logging
* level to use when logging a there is no reply to send back.
@@ -175,26 +175,26 @@ public class Mina2ComponentConfiguration {
/**
* Whether to auto start SSL handshake.
*/
- private Boolean autoStartTls;
+ private Boolean autoStartTls = true;
/**
* Number of worker threads in the worker pool for TCP and UDP
*/
- private Integer maximumPoolSize;
+ private Integer maximumPoolSize = 16;
/**
* Whether to use ordered thread pool, to ensure events are processed
* orderly on the same channel.
*/
- private Boolean orderedThreadPoolExecutor;
+ private Boolean orderedThreadPoolExecutor = true;
/**
* Whether to create the InetAddress once and reuse. Setting this to
* false allows to pickup DNS changes in the network.
*/
- private Boolean cachedAddress;
+ private Boolean cachedAddress = true;
/**
* If the clientMode is true, mina consumer will connect the address as
* a TCP client.
*/
- private Boolean clientMode;
+ private Boolean clientMode = false;
public String getProtocol() {
return protocol;
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-nagios-starter/src/main/java/org/apache/camel/component/nagios/springboot/NagiosComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-nagios-starter/src/main/java/org/apache/camel/component/nagios/springboot/NagiosComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-nagios-starter/src/main/java/org/apache/camel/component/nagios/springboot/NagiosComponentConfiguration.java
index 52b8e6c..a621c46 100644
--- a/platforms/spring-boot/components-starter/camel-nagios-starter/src/main/java/org/apache/camel/component/nagios/springboot/NagiosComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-nagios-starter/src/main/java/org/apache/camel/component/nagios/springboot/NagiosComponentConfiguration.java
@@ -73,11 +73,11 @@ public class NagiosComponentConfiguration {
/**
* Connection timeout in millis.
*/
- private Integer connectionTimeout;
+ private Integer connectionTimeout = 5000;
/**
* Sending timeout in millis.
*/
- private Integer timeout;
+ private Integer timeout = 5000;
/**
* Password to be authenticated when sending checks to Nagios.
*/
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
----------------------------------------------------------------------
diff --git a/platforms/spring-boot/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
index 18d7ccd..5b2c499 100644
--- a/platforms/spring-boot/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-netty-http-starter/src/main/java/org/apache/camel/component/netty/http/springboot/NettyHttpComponentConfiguration.java
@@ -137,13 +137,13 @@ public class NettyHttpComponentConfiguration {
* Allow using gzip/deflate for compression on the Netty HTTP server if
* the client supports it from the HTTP headers.
*/
- private Boolean compression;
+ private Boolean compression = false;
/**
* Option to disable throwing the HttpOperationFailedException in case
* of failed responses from the remote server. This allows you to get
* all responses regardless of the HTTP status code.
*/
- private Boolean throwExceptionOnFailure;
+ private Boolean throwExceptionOnFailure = true;
/**
* If enabled and an Exchange failed processing on the consumer side,
* and if the caused Exception was send back serialized in the response
@@ -156,7 +156,7 @@ public class NettyHttpComponentConfiguration {
* Java will deserialize the incoming data from the request to Java and
* that can be a potential security risk.
*/
- private Boolean transferException;
+ private Boolean transferException = false;
/**
* If this option is enabled, then during binding from Netty to Camel
* Message then the header values will be URL decoded (eg %20 will be a
@@ -166,7 +166,7 @@ public class NettyHttpComponentConfiguration {
* org.apache.camel.component.netty.http.NettyHttpBinding then you would
* need to decode the headers accordingly to this option.
*/
- private Boolean urlDecodeHeaders;
+ private Boolean urlDecodeHeaders = false;
/**
* If this option is enabled, then during binding from Netty to Camel
* Message then the headers will be mapped as well (eg added as header
@@ -176,12 +176,12 @@ public class NettyHttpComponentConfiguration {
* the method getHttpRequest() that returns the Netty HTTP request
* org.jboss.netty.handler.codec.http.HttpRequest instance.
*/
- private Boolean mapHeaders;
+ private Boolean mapHeaders = true;
/**
* Whether or not Camel should try to find a target consumer by matching
* the URI prefix if no exact match is found.
*/
- private Boolean matchOnUriPrefix;
+ private Boolean matchOnUriPrefix = false;
/**
* If the option is true, the producer will ignore the Exchange.HTTP_URI
* header, and use the endpoint's URI for request. You may also set the
@@ -191,7 +191,7 @@ public class NettyHttpComponentConfiguration {
* Exchange.SKIP_GZIP_ENCODING and Exchange.SKIP_WWW_FORM_URLENCODED
* headers to the consumed exchange).
*/
- private Boolean bridgeEndpoint;
+ private Boolean bridgeEndpoint = false;
/**
* Resource path
*/
@@ -209,24 +209,24 @@ public class NettyHttpComponentConfiguration {
* and you would need manually to reset the reader index on the Netty
* raw stream.
*/
- private Boolean disableStreamCache;
+ private Boolean disableStreamCache = false;
/**
* Whether to send back HTTP status code 503 when the consumer has been
* suspended. If the option is false then the Netty Acceptor is unbound
* when the consumer is suspended, so clients cannot connect anymore.
*/
- private Boolean send503whenSuspended;
+ private Boolean send503whenSuspended = true;
/**
* Value in bytes the max content length per chunked frame received on
* the Netty HTTP server.
*/
- private Integer chunkedMaxContentLength;
+ private Integer chunkedMaxContentLength = 1048576;
/**
* The maximum length of all headers. If the sum of the length of each
* header exceeds this value, a {@link TooLongFrameException} will be
* raised.
*/
- private Integer maxHeaderSize;
+ private Integer maxHeaderSize = 8192;
private Boolean allowDefaultCodec;
/**
* The status codes which is considered a success response. The values
@@ -243,7 +243,7 @@ public class NettyHttpComponentConfiguration {
* absolute URIs in HTTP POSTs, and setting this option to <tt>true</tt>
* can work around this problem.
*/
- private Boolean useRelativePath;
+ private Boolean useRelativePath = false;
public String getProtocol() {
return protocol;