Repository: camel Updated Branches: refs/heads/master cb459e65f -> d4d574fd1
http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java index 1f6c05e..9471f30 100644 --- a/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java @@ -97,17 +97,17 @@ public class NettyComponentConfiguration { /** * 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; /** * The max line length to use for the textline codec. */ - private Integer decoderMaxLineLength; + private Integer decoderMaxLineLength = 1024; /** * The delimiter to use for the textline codec. Possible values are LINE * and NULL. @@ -117,7 +117,7 @@ public class NettyComponentConfiguration { * Whether or not to auto append missing end delimiter when sending * using the textline codec. */ - private Boolean autoAppendDelimiter; + private Boolean autoAppendDelimiter = true; /** * The encoding (a charset name) to use for the textline codec. If not * provided, Camel will use the JVM default Charset. @@ -155,12 +155,12 @@ public class NettyComponentConfiguration { * Whether or not to disconnect(close) from Netty Channel right after * use. Can be used for both consumer and producer. */ - private Boolean disconnect; + private Boolean disconnect = false; /** * Channels can be lazily created to avoid exceptions, if the remote * server is not up and running when the Camel producer is started. */ - private Boolean lazyChannelCreation; + private Boolean lazyChannelCreation = true; /** * Only used for TCP. You can transfer the exchange over the wire * instead of just the body. The following fields are transferred: In @@ -169,12 +169,12 @@ public class NettyComponentConfiguration { * objects are serializable. Camel will exclude any non-serializable * objects and log it at WARN level. */ - private Boolean transferExchange; + private Boolean transferExchange = false; /** * If sync is enabled then this option dictates NettyConsumer 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 NettyConsumer which logging * level to use when logging a there is no reply to send back. @@ -199,7 +199,7 @@ public class NettyComponentConfiguration { * prevents the netty component from installing a default codec as the * first element in the filter chain. */ - private Boolean allowDefaultCodec; + private Boolean allowDefaultCodec = true; /** * To use a custom ClientPipelineFactory */ @@ -213,13 +213,13 @@ public class NettyComponentConfiguration { * .netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor for * more details. */ - private Boolean orderedThreadPoolExecutor; + private Boolean orderedThreadPoolExecutor = true; /** * Sets the cap on the number of objects that can be allocated by the * pool (checked out to clients, or idle awaiting checkout) at a given * time. Use a negative value for no limit. */ - private Integer producerPoolMaxActive; + private Integer producerPoolMaxActive = -1; /** * Sets the minimum number of instances allowed in the producer pool * before the evictor thread (if active) spawns new objects. @@ -228,45 +228,45 @@ public class NettyComponentConfiguration { /** * Sets the cap on the number of "idle" instances in the pool. */ - private Integer producerPoolMaxIdle; + private Integer producerPoolMaxIdle = 100; /** * Sets the minimum amount of time (value in millis) an object may sit * idle in the pool before it is eligible for eviction by the idle * object evictor. */ - private Long producerPoolMinEvictableIdle; + private Long producerPoolMinEvictableIdle = 300000L; /** * Whether producer pool is enabled or not. Important: Do not turn this * off, as the pooling is needed for handling concurrency and reliable * request/reply. */ - private Boolean producerPoolEnabled; + private Boolean producerPoolEnabled = true; /** * This option supports connection less udp sending which is a real fire * and forget. A connected udp send receive the PortUnreachableException * if no one is listen on the receiving port. */ - private Boolean udpConnectionlessSending; + private Boolean udpConnectionlessSending = false; /** * If the clientMode is true, netty consumer will connect the address as * a TCP client. */ - private Boolean clientMode; + private Boolean clientMode = false; /** * If the useChannelBuffer is true, netty producer will turn the message * body into {@link ChannelBuffer} before sending it out. */ - private Boolean useChannelBuffer; + private Boolean useChannelBuffer = false; /** * The maximum total size of the queued events per channel when using * orderedThreadPoolExecutor. Specify 0 to disable. */ - private Long maxChannelMemorySize; + private Long maxChannelMemorySize = 10485760L; /** * The maximum total size of the queued events for this pool when using * orderedThreadPoolExecutor. Specify 0 to disable. */ - private Long maxTotalMemorySize; + private Long maxTotalMemorySize = 209715200L; /** * The protocol to use which can be tcp or udp. */ @@ -285,17 +285,17 @@ public class NettyComponentConfiguration { /** * Setting to choose Multicast over UDP */ - private Boolean broadcast; + private Boolean broadcast = false; /** * The TCP/UDP buffer sizes to be used during outbound communication. * Size is bytes. */ - private Long sendBufferSize; + private Long sendBufferSize = 65536L; /** * The TCP/UDP buffer sizes to be used during inbound communication. * Size is bytes. */ - private Long receiveBufferSize; + private Long receiveBufferSize = 65536L; /** * Configures the buffer size predictor. See details at Jetty * documentation and this mail thread. @@ -312,24 +312,24 @@ public class NettyComponentConfiguration { * from Netty, which is 1. User can use this operation to override the * default bossCount from Netty */ - private Integer bossCount; + private Integer bossCount = 1; /** * Setting to ensure socket is not closed due to inactivity */ - private Boolean keepAlive; + private Boolean keepAlive = true; /** * Setting to improve TCP protocol performance */ - private Boolean tcpNoDelay; + private Boolean tcpNoDelay = true; /** * Setting to facilitate socket multiplexing */ - private Boolean reuseAddress; + private Boolean reuseAddress = true; /** * Time to wait for a socket connection to be available. Value is in * millis. */ - private Long connectTimeout; + private Long connectTimeout = 10000L; /** * Allows to configure a backlog for netty consumer (server). Note the * backlog is just a best effort depending on the OS. Setting this @@ -341,14 +341,14 @@ public class NettyComponentConfiguration { /** * Setting to specify whether SSL encryption is applied to this endpoint */ - private Boolean ssl; + private Boolean ssl = false; /** * When enabled and in SSL mode, then the Netty consumer will enrich the * Camel Message with headers having information about the client * certificate such as subject name, issuer name, serial number, and the * valid date range. */ - private Boolean sslClientCertHeaders; + private Boolean sslClientCertHeaders = false; /** * Reference to a class that could be used to return an SSL Handler */ @@ -363,7 +363,7 @@ public class NettyComponentConfiguration { * Configures whether the server needs client authentication when using * SSL. */ - private Boolean needClientAuth; + private Boolean needClientAuth = false; /** * Client side certificate keystore to be used for encryption */ @@ -442,7 +442,7 @@ public class NettyComponentConfiguration { /** * Which protocols to enable when using SSL */ - private String enabledProtocols = org.apache.camel.component.netty.NettyConfiguration.DEFAULT_ENABLED_PROTOCOLS; + private String enabledProtocols = "TLSv1,TLSv1.1,TLSv1.2"; public Long getRequestTimeout() { return requestTimeout; http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-netty4-http-starter/src/main/java/org/apache/camel/component/netty4/http/springboot/NettyHttpComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-netty4-http-starter/src/main/java/org/apache/camel/component/netty4/http/springboot/NettyHttpComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-netty4-http-starter/src/main/java/org/apache/camel/component/netty4/http/springboot/NettyHttpComponentConfiguration.java index ac3a271..df38552 100644 --- a/platforms/spring-boot/components-starter/camel-netty4-http-starter/src/main/java/org/apache/camel/component/netty4/http/springboot/NettyHttpComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-netty4-http-starter/src/main/java/org/apache/camel/component/netty4/http/springboot/NettyHttpComponentConfiguration.java @@ -151,13 +151,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 @@ -170,7 +170,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 @@ -180,7 +180,7 @@ public class NettyHttpComponentConfiguration { * org.apache.camel.component.netty4.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 @@ -190,12 +190,12 @@ public class NettyHttpComponentConfiguration { * the method getHttpRequest() that returns the Netty HTTP request * io.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 @@ -205,7 +205,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 */ @@ -228,24 +228,24 @@ public class NettyHttpComponentConfiguration { * {@link org.apache.camel.Exchange} may not be able to read the Netty * stream, because Netty has closed it. */ - 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 io.netty.handler.codec.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 @@ -258,7 +258,7 @@ public class NettyHttpComponentConfiguration { /** * Sets whether to use a relative path in HTTP requests. */ - private Boolean useRelativePath; + private Boolean useRelativePath = false; public String getProtocol() { return protocol; http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-netty4-starter/src/main/java/org/apache/camel/component/netty4/springboot/NettyComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-netty4-starter/src/main/java/org/apache/camel/component/netty4/springboot/NettyComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-netty4-starter/src/main/java/org/apache/camel/component/netty4/springboot/NettyComponentConfiguration.java index 8981d12..4737105 100644 --- a/platforms/spring-boot/components-starter/camel-netty4-starter/src/main/java/org/apache/camel/component/netty4/springboot/NettyComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-netty4-starter/src/main/java/org/apache/camel/component/netty4/springboot/NettyComponentConfiguration.java @@ -110,17 +110,17 @@ public class NettyComponentConfiguration { /** * 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; /** * The max line length to use for the textline codec. */ - private Integer decoderMaxLineLength; + private Integer decoderMaxLineLength = 1024; /** * The delimiter to use for the textline codec. Possible values are LINE * and NULL. @@ -130,7 +130,7 @@ public class NettyComponentConfiguration { * Whether or not to auto append missing end delimiter when sending * using the textline codec. */ - private Boolean autoAppendDelimiter; + private Boolean autoAppendDelimiter = true; /** * The encoding (a charset name) to use for the textline codec. If not * provided, Camel will use the JVM default Charset. @@ -166,12 +166,12 @@ public class NettyComponentConfiguration { * Whether or not to disconnect(close) from Netty Channel right after * use. Can be used for both consumer and producer. */ - private Boolean disconnect; + private Boolean disconnect = false; /** * Channels can be lazily created to avoid exceptions, if the remote * server is not up and running when the Camel producer is started. */ - private Boolean lazyChannelCreation; + private Boolean lazyChannelCreation = true; /** * Only used for TCP. You can transfer the exchange over the wire * instead of just the body. The following fields are transferred: In @@ -180,19 +180,19 @@ public class NettyComponentConfiguration { * objects are serializable. Camel will exclude any non-serializable * objects and log it at WARN level. */ - private Boolean transferExchange; + private Boolean transferExchange = false; /** * Only used for TCP when transferExchange is true. When set to true, * serializable objects in headers and properties will be added to the * exchange. Otherwise Camel will exclude any non-serializable objects * and log it at WARN level. */ - private Boolean allowSerializedHeaders; + private Boolean allowSerializedHeaders = false; /** * If sync is enabled then this option dictates NettyConsumer 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 NettyConsumer which logging * level to use when logging a there is no reply to send back. @@ -217,7 +217,7 @@ public class NettyComponentConfiguration { * prevents the netty component from installing a default codec as the * first element in the filter chain. */ - private Boolean allowDefaultCodec; + private Boolean allowDefaultCodec = true; /** * @deprecated use #setClientInitializerFactory */ @@ -231,13 +231,13 @@ public class NettyComponentConfiguration { * Whether to use ordered thread pool, to ensure events are processed * orderly on the same channel. */ - private Boolean usingExecutorService; + private Boolean usingExecutorService = true; /** * Sets the cap on the number of objects that can be allocated by the * pool (checked out to clients, or idle awaiting checkout) at a given * time. Use a negative value for no limit. */ - private Integer producerPoolMaxActive; + private Integer producerPoolMaxActive = -1; /** * Sets the minimum number of instances allowed in the producer pool * before the evictor thread (if active) spawns new objects. @@ -246,40 +246,40 @@ public class NettyComponentConfiguration { /** * Sets the cap on the number of "idle" instances in the pool. */ - private Integer producerPoolMaxIdle; + private Integer producerPoolMaxIdle = 100; /** * Sets the minimum amount of time (value in millis) an object may sit * idle in the pool before it is eligible for eviction by the idle * object evictor. */ - private Long producerPoolMinEvictableIdle; + private Long producerPoolMinEvictableIdle = 300000L; /** * Whether producer pool is enabled or not. Important: Do not turn this * off, as the pooling is needed for handling concurrency and reliable * request/reply. */ - private Boolean producerPoolEnabled; + private Boolean producerPoolEnabled = true; /** * This option supports connection less udp sending which is a real fire * and forget. A connected udp send receive the PortUnreachableException * if no one is listen on the receiving port. */ - private Boolean udpConnectionlessSending; + private Boolean udpConnectionlessSending = false; /** * If the clientMode is true, netty consumer will connect the address as * a TCP client. */ - private Boolean clientMode; + private Boolean clientMode = false; /** * If the useByteBuf is true, netty producer will turn the message body * into {@link ByteBuf} before sending it out. */ - private Boolean useByteBuf; + private Boolean useByteBuf = false; /** * For UDP only. If enabled the using byte array codec instead of Java * serialization protocol. */ - private Boolean udpByteArrayCodec; + private Boolean udpByteArrayCodec = false; /** * This option allows producers to reuse the same Netty {@link Channel} * for the lifecycle of processing the {@link Exchange} . This is @@ -294,7 +294,7 @@ public class NettyComponentConfiguration { * which allows you to obtain the channel during routing and use it as * well. */ - private Boolean reuseChannel; + private Boolean reuseChannel = false; /** * The protocol to use which can be tcp or udp. */ @@ -313,17 +313,17 @@ public class NettyComponentConfiguration { /** * Setting to choose Multicast over UDP */ - private Boolean broadcast; + private Boolean broadcast = false; /** * The TCP/UDP buffer sizes to be used during outbound communication. * Size is bytes. */ - private Integer sendBufferSize; + private Integer sendBufferSize = 65536; /** * The TCP/UDP buffer sizes to be used during inbound communication. * Size is bytes. */ - private Integer receiveBufferSize; + private Integer receiveBufferSize = 65536; /** * Configures the buffer size predictor. See details at Jetty * documentation and this mail thread. @@ -340,24 +340,24 @@ public class NettyComponentConfiguration { * from Netty, which is 1. User can use this operation to override the * default bossCount from Netty */ - private Integer bossCount; + private Integer bossCount = 1; /** * Setting to ensure socket is not closed due to inactivity */ - private Boolean keepAlive; + private Boolean keepAlive = true; /** * Setting to improve TCP protocol performance */ - private Boolean tcpNoDelay; + private Boolean tcpNoDelay = true; /** * Setting to facilitate socket multiplexing */ - private Boolean reuseAddress; + private Boolean reuseAddress = true; /** * Time to wait for a socket connection to be available. Value is in * millis. */ - private Integer connectTimeout; + private Integer connectTimeout = 10000; /** * Allows to configure a backlog for netty consumer (server). Note the * backlog is just a best effort depending on the OS. Setting this @@ -369,14 +369,14 @@ public class NettyComponentConfiguration { /** * Setting to specify whether SSL encryption is applied to this endpoint */ - private Boolean ssl; + private Boolean ssl = false; /** * When enabled and in SSL mode, then the Netty consumer will enrich the * Camel Message with headers having information about the client * certificate such as subject name, issuer name, serial number, and the * valid date range. */ - private Boolean sslClientCertHeaders; + private Boolean sslClientCertHeaders = false; /** * Reference to a class that could be used to return an SSL Handler */ @@ -391,7 +391,7 @@ public class NettyComponentConfiguration { * Configures whether the server needs client authentication when using * SSL. */ - private Boolean needClientAuth; + private Boolean needClientAuth = false; /** * Client side certificate keystore to be used for encryption */ @@ -456,7 +456,7 @@ public class NettyComponentConfiguration { * system you are using. See more details at: * http://netty.io/wiki/native-transports.html */ - private Boolean nativeTransport; + private Boolean nativeTransport = false; /** * Set the BossGroup which could be used for handling the new connection * of the server side across the NettyEndpoint @@ -481,9 +481,9 @@ public class NettyComponentConfiguration { /** * Which protocols to enable when using SSL */ - private String enabledProtocols = org.apache.camel.component.netty4.NettyConfiguration.DEFAULT_ENABLED_PROTOCOLS; - private Boolean reconnect; - private Integer reconnectInterval; + private String enabledProtocols = "TLSv1,TLSv1.1,TLSv1.2"; + private Boolean reconnect = true; + private Integer reconnectInterval = 10000; public Long getRequestTimeout() { return requestTimeout; http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-olingo2-starter/src/main/java/org/apache/camel/component/olingo2/springboot/Olingo2ComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-olingo2-starter/src/main/java/org/apache/camel/component/olingo2/springboot/Olingo2ComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-olingo2-starter/src/main/java/org/apache/camel/component/olingo2/springboot/Olingo2ComponentConfiguration.java index b9f9fd1..e0029cf 100644 --- a/platforms/spring-boot/components-starter/camel-olingo2-starter/src/main/java/org/apache/camel/component/olingo2/springboot/Olingo2ComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-olingo2-starter/src/main/java/org/apache/camel/component/olingo2/springboot/Olingo2ComponentConfiguration.java @@ -91,11 +91,11 @@ public class Olingo2ComponentConfiguration { * HTTP connection creation timeout in milliseconds, defaults to 30,000 * (30 seconds) */ - private Integer connectTimeout; + private Integer connectTimeout = 30000; /** * HTTP request timeout in milliseconds, defaults to 30,000 (30 seconds) */ - private Integer socketTimeout; + private Integer socketTimeout = 30000; /** * HTTP proxy server configuration */ http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java index 5819e08..dbff830 100644 --- a/platforms/spring-boot/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-salesforce-starter/src/main/java/org/apache/camel/component/salesforce/springboot/SalesforceComponentConfiguration.java @@ -518,7 +518,7 @@ public class SalesforceComponentConfiguration { * Whether to update an existing Push Topic when using the Streaming * API, defaults to false */ - private Boolean updateTopic; + private Boolean updateTopic = false; /** * Notify for fields, options are ALL, REFERENCED, SELECT, WHERE */ http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-servicenow-starter/src/main/java/org/apache/camel/component/servicenow/springboot/ServiceNowComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-servicenow-starter/src/main/java/org/apache/camel/component/servicenow/springboot/ServiceNowComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-servicenow-starter/src/main/java/org/apache/camel/component/servicenow/springboot/ServiceNowComponentConfiguration.java index f451cb0..9b4bd95 100644 --- a/platforms/spring-boot/components-starter/camel-servicenow-starter/src/main/java/org/apache/camel/component/servicenow/springboot/ServiceNowComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-servicenow-starter/src/main/java/org/apache/camel/component/servicenow/springboot/ServiceNowComponentConfiguration.java @@ -247,7 +247,7 @@ public class ServiceNowComponentConfiguration { * Enter the maximum number of scorecards each query can return. By * default this value is 10, and the maximum is 100. */ - private Integer perPage; + private Integer perPage = 10; /** * Specify the value to use when sorting results. By default, queries * sort records by value. http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-smpp-starter/src/main/java/org/apache/camel/component/smpp/springboot/SmppComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-smpp-starter/src/main/java/org/apache/camel/component/smpp/springboot/SmppComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-smpp-starter/src/main/java/org/apache/camel/component/smpp/springboot/SmppComponentConfiguration.java index 9ec56cb..a0f489f 100644 --- a/platforms/spring-boot/components-starter/camel-smpp-starter/src/main/java/org/apache/camel/component/smpp/springboot/SmppComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-smpp-starter/src/main/java/org/apache/camel/component/smpp/springboot/SmppComponentConfiguration.java @@ -68,7 +68,7 @@ public class SmppComponentConfiguration { /** * Port number for the SMSC server to use. */ - private Integer port; + private Integer port = 2775; /** * The system id (username) for connecting to SMSC server. */ @@ -106,14 +106,14 @@ public class SmppComponentConfiguration { * The confidence check is used to test the communication path between * an ESME and an SMSC. */ - private Integer enquireLinkTimer; + private Integer enquireLinkTimer = 5000; /** * Defines the maximum period of inactivity allowed after a transaction, * after which an SMPP entity may assume that the session is no longer * active. This timer may be active on either communicating SMPP entity * (i.e. SMSC or ESME). */ - private Integer transactionTimer; + private Integer transactionTimer = 10000; /** * This parameter is used to categorize the type of ESME (External Short * Message Entity) that is binding to the SMSC (max. 13 characters). @@ -282,19 +282,19 @@ public class SmppComponentConfiguration { /** * Whether using SSL with the smpps protocol */ - private Boolean usingSSL; + private Boolean usingSSL = false; /** * Defines the initial delay in milliseconds after the consumer/producer * tries to reconnect to the SMSC, after the connection was lost. */ - private Long initialReconnectDelay; + private Long initialReconnectDelay = 5000L; /** * Defines the interval in milliseconds between the reconnect attempts, * if the connection to the SMSC was lost and the previous was not * succeed. */ - private Long reconnectDelay; - private Integer maxReconnect; + private Long reconnectDelay = 5000L; + private Integer maxReconnect = 2147483647; /** * Sessions can be lazily created to avoid exceptions, if the SMSC is * not available when the Camel producer is started. Camel will check @@ -302,7 +302,7 @@ public class SmppComponentConfiguration { * the first exchange. If they are present, Camel will use these data to * connect to the SMSC. */ - private Boolean lazySessionCreation; + private Boolean lazySessionCreation = false; /** * If you need to tunnel SMPP through a HTTP proxy, set this attribute * to the hostname or ip address of your HTTP proxy. @@ -312,7 +312,7 @@ public class SmppComponentConfiguration { * If you need to tunnel SMPP through a HTTP proxy, set this attribute * to the port of your HTTP proxy. */ - private Integer httpProxyPort; + private Integer httpProxyPort = 3128; /** * If your HTTP proxy requires basic authentication, set this attribute * to the username required for your HTTP proxy. http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-ssh-starter/src/main/java/org/apache/camel/component/ssh/springboot/SshComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-ssh-starter/src/main/java/org/apache/camel/component/ssh/springboot/SshComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-ssh-starter/src/main/java/org/apache/camel/component/ssh/springboot/SshComponentConfiguration.java index 03f4d82..4befc2f 100644 --- a/platforms/spring-boot/components-starter/camel-ssh-starter/src/main/java/org/apache/camel/component/ssh/springboot/SshComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-ssh-starter/src/main/java/org/apache/camel/component/ssh/springboot/SshComponentConfiguration.java @@ -217,7 +217,7 @@ public class SshComponentConfiguration { * int representing port number on remote host. Defaults to * 22. */ - private Integer port; + private Integer port = 22; /** * Sets the password to use in connecting to remote SSH server. Requires * keyPairProvider to be set to null. @@ -257,7 +257,7 @@ public class SshComponentConfiguration { * authentication. * @see KeyPairProvider */ - private String keyType = org.apache.sshd.common.KeyPairProvider.SSH_RSA; + private String keyType = "ssh-rsa"; /** * Sets the timeout in milliseconds to wait in establishing the remote * SSH server connection. Defaults to 30000 milliseconds. @@ -265,7 +265,7 @@ public class SshComponentConfiguration { * @param timeout * long milliseconds to wait. */ - private Long timeout; + private Long timeout = 30000L; /** * @deprecated As of version 2.11, replaced by * {@link #setCertResource(String)} http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-xmlsecurity-starter/src/main/java/org/apache/camel/component/xmlsecurity/springboot/XmlSignatureComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-xmlsecurity-starter/src/main/java/org/apache/camel/component/xmlsecurity/springboot/XmlSignatureComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-xmlsecurity-starter/src/main/java/org/apache/camel/component/xmlsecurity/springboot/XmlSignatureComponentConfiguration.java index e6e1f04..443724d 100644 --- a/platforms/spring-boot/components-starter/camel-xmlsecurity-starter/src/main/java/org/apache/camel/component/xmlsecurity/springboot/XmlSignatureComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-xmlsecurity-starter/src/main/java/org/apache/camel/component/xmlsecurity/springboot/XmlSignatureComponentConfiguration.java @@ -132,7 +132,7 @@ public class XmlSignatureComponentConfiguration { * Only relevant when a KeyInfo is returned by {@link KeyAccessor} . and * {@link KeyInfo#getId()} is not <code>null</code>. */ - private Boolean addKeyInfoReference; + private Boolean addKeyInfoReference = true; /** * Namespace prefix for the XML signature namespace * "http://www.w3.org/2000/09/xmldsig#";. Default value is "ds". If @@ -206,7 +206,7 @@ public class XmlSignatureComponentConfiguration { * contains XML. The value can be overwritten by the header * {@link XmlSignatureConstants#HEADER_MESSAGE_IS_PLAIN_TEXT} . */ - private Boolean plainText; + private Boolean plainText = false; /** * Encoding of the plain text. Only relevant if the message body is * plain text (see parameter {@link #plainText} . Default value is @@ -301,19 +301,19 @@ public class XmlSignatureComponentConfiguration { * if set to {@link Boolean#FALSE} then DOCTYPE declaration * is allowed, otherwise not */ - private Boolean disallowDoctypeDecl; + private Boolean disallowDoctypeDecl = true; /** * Indicator whether the XML declaration in the outgoing message body * should be omitted. Default value is <code>false</code>. Can be * overwritten by the header * {@link XmlSignatureConstants#HEADER_OMIT_XML_DECLARATION} . */ - private Boolean omitXmlDeclaration; + private Boolean omitXmlDeclaration = false; /** * Determines if the XML signature specific headers be cleared after * signing and verification. Defaults to true. */ - private Boolean clearHeaders; + private Boolean clearHeaders = true; /** * Classpath to the XML Schema. Must be specified in the detached XML * Signature case for determining the ID attributes, might be set in the @@ -644,7 +644,7 @@ public class XmlSignatureComponentConfiguration { * {@link #setOutputNodeSearch(Object)} . The supported default search * types you can find in {@link DefaultXmlSignature2Message} . */ - private String outputNodeSearchType = org.apache.camel.component.xmlsecurity.api.DefaultXmlSignature2Message.OUTPUT_NODE_SEARCH_TYPE_DEFAULT; + private String outputNodeSearchType = "Default"; /** * Indicator whether the XML signature elements (elements with local * name "Signature" and namesapce @@ -658,11 +658,11 @@ public class XmlSignatureComponentConfiguration { * {@link DefaultXmlSignature2Message#OUTPUT_NODE_SEARCH_TYPE_DEFAULT} * .F */ - private Boolean removeSignatureElements; + private Boolean removeSignatureElements = false; /** * Enables secure validation. If true then secure validation is enabled. */ - private Boolean secureValidation; + private Boolean secureValidation = true; /** * Name of handler to * @@ -711,19 +711,19 @@ public class XmlSignatureComponentConfiguration { * if set to {@link Boolean#FALSE} then DOCTYPE declaration * is allowed, otherwise not */ - private Boolean disallowDoctypeDecl; + private Boolean disallowDoctypeDecl = true; /** * Indicator whether the XML declaration in the outgoing message body * should be omitted. Default value is <code>false</code>. Can be * overwritten by the header * {@link XmlSignatureConstants#HEADER_OMIT_XML_DECLARATION} . */ - private Boolean omitXmlDeclaration; + private Boolean omitXmlDeclaration = false; /** * Determines if the XML signature specific headers be cleared after * signing and verification. Defaults to true. */ - private Boolean clearHeaders; + private Boolean clearHeaders = true; /** * Classpath to the XML Schema. Must be specified in the detached XML * Signature case for determining the ID attributes, might be set in the http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-yammer-starter/src/main/java/org/apache/camel/component/yammer/springboot/YammerComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-yammer-starter/src/main/java/org/apache/camel/component/yammer/springboot/YammerComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-yammer-starter/src/main/java/org/apache/camel/component/yammer/springboot/YammerComponentConfiguration.java index 780d9f5..1168a36 100644 --- a/platforms/spring-boot/components-starter/camel-yammer-starter/src/main/java/org/apache/camel/component/yammer/springboot/YammerComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-yammer-starter/src/main/java/org/apache/camel/component/yammer/springboot/YammerComponentConfiguration.java @@ -106,7 +106,7 @@ public class YammerComponentConfiguration { /** * Delay between polling in millis */ - private Long delay; + private Long delay = 5000L; /** * The access token */ @@ -123,13 +123,13 @@ public class YammerComponentConfiguration { * Set to true if you want to use raw JSON rather than converting to * POJOs. */ - private Boolean useJson; + private Boolean useJson = false; private ApiRequestor requestor; /** * Return only the specified number of messages. Works for threaded=true * and threaded=extended. */ - private Integer limit; + private Integer limit = -1; /** * Returns messages older than the message ID specified as a numeric * string. This is useful for paginating messages. For example, if @@ -137,7 +137,7 @@ public class YammerComponentConfiguration { * you could append "?olderThan=2912â³ to your request to get the 20 * messages prior to those you're seeing. */ - private Integer olderThan; + private Integer olderThan = -1; /** * Returns messages newer than the message ID specified as a numeric * string. This should be used when polling for new messages. If you're @@ -146,7 +146,7 @@ public class YammerComponentConfiguration { * that you do not get duplicate copies of messages already on your * page. */ - private Integer newerThan; + private Integer newerThan = -1; /** * threaded=true will only return the first message in each thread. This * parameter is intended for apps which display message threads http://git-wip-us.apache.org/repos/asf/camel/blob/d4d574fd/platforms/spring-boot/components-starter/camel-zookeeper-starter/src/main/java/org/apache/camel/component/zookeeper/springboot/ZooKeeperComponentConfiguration.java ---------------------------------------------------------------------- diff --git a/platforms/spring-boot/components-starter/camel-zookeeper-starter/src/main/java/org/apache/camel/component/zookeeper/springboot/ZooKeeperComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-zookeeper-starter/src/main/java/org/apache/camel/component/zookeeper/springboot/ZooKeeperComponentConfiguration.java index 6c424ab..7f40e02 100644 --- a/platforms/spring-boot/components-starter/camel-zookeeper-starter/src/main/java/org/apache/camel/component/zookeeper/springboot/ZooKeeperComponentConfiguration.java +++ b/platforms/spring-boot/components-starter/camel-zookeeper-starter/src/main/java/org/apache/camel/component/zookeeper/springboot/ZooKeeperComponentConfiguration.java @@ -66,11 +66,11 @@ public class ZooKeeperComponentConfiguration { /** * The time interval to wait on connection before timing out. */ - private Integer timeout; + private Integer timeout = 5000; /** * Whether the children of the node should be listed */ - private Boolean listChildren; + private Boolean listChildren = false; /** * The node in the ZooKeeper server (aka znode) */ @@ -78,22 +78,22 @@ public class ZooKeeperComponentConfiguration { /** * Should changes to the znode be 'watched' and repeatedly processed. */ - private Boolean repeat; + private Boolean repeat = false; /** * Not in use * * @deprecated The usage of this option has no effect at all. */ @Deprecated - private Boolean awaitExistence; + private Boolean awaitExistence = true; /** * The time interval to backoff for after an error before retrying. */ - private Long backoff; + private Long backoff = 5000L; /** * Should the endpoint create the node if it does not currently exist. */ - private Boolean create; + private Boolean create = false; /** * The create mode that should be used for the newly created node */ @@ -102,7 +102,7 @@ public class ZooKeeperComponentConfiguration { * Upon the delete of a znode, should an empty message be send to the * consumer */ - private Boolean sendEmptyMessageOnDelete; + private Boolean sendEmptyMessageOnDelete = true; public List getServers() { return servers;
