camel git commit: Upgrade Jackson to version 2.5.4
Repository: camel Updated Branches: refs/heads/master 3bf0588cc - 722a588e7 Upgrade Jackson to version 2.5.4 Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/722a588e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/722a588e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/722a588e Branch: refs/heads/master Commit: 722a588e75b4660b8ce6ca3c654d0c4efec56659 Parents: 3bf0588 Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 11:17:31 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 11:17:31 2015 +0200 -- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/722a588e/parent/pom.xml -- diff --git a/parent/pom.xml b/parent/pom.xml index fd053b6..7ee4d62 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -233,7 +233,7 @@ ivy-version2.4.0/ivy-version jini-version2.1/jini-version jackson-version1.9.12/jackson-version -jackson2-version2.5.3/jackson2-version +jackson2-version2.5.4/jackson2-version jackrabbit-version2.10.0/jackrabbit-version jain-sip-ri-bundle-version1.2.154_2/jain-sip-ri-bundle-version jasper-bundle-version6.0.36_1/jasper-bundle-version
[5/5] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e20ae861 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e20ae861 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e20ae861 Branch: refs/heads/master Commit: e20ae861b79af7c1a7245abbc67e591af846875f Parents: a4e6997 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 13:05:27 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 13:08:08 2015 +0200 -- .../component/websocket/WebsocketComponent.java | 32 +++- .../component/websocket/WebsocketEndpoint.java | 80 2 files changed, 95 insertions(+), 17 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/e20ae861/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java -- diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java index 33afc99..379c730 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java @@ -650,8 +650,6 @@ public class WebsocketComponent extends UriEndpointComponent { * ttclasspath:WEB-INF/static/tt * p/ * If not configured (eg ttnull/tt) then no static resource is in use. - * - * @param staticResources the base path */ public void setStaticResources(String staticResources) { this.staticResources = staticResources; @@ -661,6 +659,9 @@ public class WebsocketComponent extends UriEndpointComponent { return host; } +/** + * The hostname. The default value is tt0.0.0.0/tt + */ public void setHost(String host) { this.host = host; } @@ -669,6 +670,9 @@ public class WebsocketComponent extends UriEndpointComponent { return port; } +/** + * The port number. The default value is tt9292/tt + */ public void setPort(Integer port) { this.port = port; } @@ -685,18 +689,30 @@ public class WebsocketComponent extends UriEndpointComponent { return sslKeystore; } +/** + * The password for the keystore when using SSL. + */ public void setSslKeyPassword(String sslKeyPassword) { this.sslKeyPassword = sslKeyPassword; } +/** + * The password when using SSL. + */ public void setSslPassword(String sslPassword) { this.sslPassword = sslPassword; } +/** + * The path to the keystore. + */ public void setSslKeystore(String sslKeystore) { this.sslKeystore = sslKeystore; } +/** + * If this option is true, Jetty JMX support will be enabled for this endpoint. See Jetty JMX support for more details. + */ public void setEnableJmx(boolean enableJmx) { this.enableJmx = enableJmx; } @@ -709,6 +725,9 @@ public class WebsocketComponent extends UriEndpointComponent { return minThreads; } +/** + * To set a value for minimum number of threads in server thread pool. + */ public void setMinThreads(Integer minThreads) { this.minThreads = minThreads; } @@ -717,6 +736,9 @@ public class WebsocketComponent extends UriEndpointComponent { return maxThreads; } +/** + * To set a value for maximum number of threads in server thread pool. + */ public void setMaxThreads(Integer maxThreads) { this.maxThreads = maxThreads; } @@ -725,6 +747,9 @@ public class WebsocketComponent extends UriEndpointComponent { return threadPool; } +/** + * To use a custom thread pool for the server. + */ public void setThreadPool(ThreadPool threadPool) { this.threadPool = threadPool; } @@ -733,6 +758,9 @@ public class WebsocketComponent extends UriEndpointComponent { return sslContextParameters; } +/** + * To configure security using SSLContextParameters + */ public void setSslContextParameters(SSLContextParameters sslContextParameters) { this.sslContextParameters = sslContextParameters; } http://git-wip-us.apache.org/repos/asf/camel/blob/e20ae861/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java -- diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
camel git commit: Upgrade Jboss Weld to version 2.2.13.Final
Repository: camel Updated Branches: refs/heads/master 359bf0e45 - 62428565a Upgrade Jboss Weld to version 2.2.13.Final Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/62428565 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/62428565 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/62428565 Branch: refs/heads/master Commit: 62428565a477a340b7687e7d1e14156a16fa7060 Parents: 359bf0e Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 14:01:05 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 14:01:05 2015 +0200 -- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/62428565/parent/pom.xml -- diff --git a/parent/pom.xml b/parent/pom.xml index 7ee4d62..ce2a7e7 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -494,7 +494,7 @@ velocity-version1.7/velocity-version vertx-version2.1.5/vertx-version vysper-version0.7/vysper-version -weld2-version2.2.11.Final/weld2-version +weld2-version2.2.13.Final/weld2-version werken-xpath-bundle-version0.9.4_5/werken-xpath-bundle-version woodstox-version4.4.1/woodstox-version ws-commons-util-bundle-version1.0.2_2/ws-commons-util-bundle-version
svn commit: r954789 - in /websites/production/camel/content: aws-ec2.html cache/main.pageCache
Author: buildbot Date: Sun Jun 14 10:18:47 2015 New Revision: 954789 Log: Production update by buildbot for camel Modified: websites/production/camel/content/aws-ec2.html websites/production/camel/content/cache/main.pageCache Modified: websites/production/camel/content/aws-ec2.html == --- websites/production/camel/content/aws-ec2.html (original) +++ websites/production/camel/content/aws-ec2.html Sun Jun 14 10:18:47 2015 @@ -95,7 +95,7 @@ h3 id=AWS-EC2-URIFormatURI Format/h3div class=code panel pdl style=border-width: 1px;div class=codeContent panelContent pdl script class=theme: Default; brush: java; gutter: false type=syntaxhighlighter![CDATA[aws-ec2://label[?options] ]]/script -/div/divpYou can append query options to the URI in the following format, ?options=valueamp;option2=valueamp;.../ph3 id=AWS-EC2-URIOptionsURI Options/h3div class=table-wraptable class=confluenceTabletbodytrth colspan=1 rowspan=1 class=confluenceThpName/p/thth colspan=1 rowspan=1 class=confluenceThpDefault Value/p/thth colspan=1 rowspan=1 class=confluenceThpContext/p/thth colspan=1 rowspan=1 class=confluenceThpDescription/p/th/trtrtd colspan=1 rowspan=1 class=confluenceTdpamazonEc2Client/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpReference to a com.amazonaws.services.ec2.AmazonEC2Client in the a shape=rect href=registry.htmlRegistry/a./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpaccessKey/p/ tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpAmazon AWS Access Key/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpsecretKey/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpAmazon AWS Secret Key/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpamazonEc2Endpoint/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpThe region with which the AWS-EC2 client wants to work with./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpoperation/p/tdtd colspan=1 rowspan =1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpValid values are createAndRunInstances, startInstances, stopInstances, terminateInstances and describeInstances/p/td/tr/tbody/table/divdiv class=aui-message hint shadowed information-macro +/div/divpYou can append query options to the URI in the following format, ?options=valueamp;option2=valueamp;.../ph3 id=AWS-EC2-URIOptionsURI Options/h3div class=table-wraptable class=confluenceTabletbodytrth colspan=1 rowspan=1 class=confluenceThpName/p/thth colspan=1 rowspan=1 class=confluenceThpDefault Value/p/thth colspan=1 rowspan=1 class=confluenceThpContext/p/thth colspan=1 rowspan=1 class=confluenceThpDescription/p/th/trtrtd colspan=1 rowspan=1 class=confluenceTdpamazonEc2Client/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpReference to a com.amazonaws.services.ec2.AmazonEC2Client in the a shape=rect href=registry.htmlRegistry/a./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpaccessKey/p/ tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpAmazon AWS Access Key/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpsecretKey/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpAmazon AWS Secret Key/p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpamazonEc2Endpoint/p/tdtd colspan=1 rowspan=1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpThe region with which the AWS-EC2 client wants to work with./p/td/trtrtd colspan=1 rowspan=1 class=confluenceTdpoperation/p/tdtd colspan=1 rowspan =1 class=confluenceTdpcodenull/code/p/tdtd colspan=1 rowspan=1 class=confluenceTdpProducer/p/tdtd colspan=1 rowspan=1 class=confluenceTdpValid values are createAndRunInstances, startInstances, stopInstances, terminateInstances, describeInstances, describeInstancesStatus, rebootInstances, monitorInstances and unmonitorInstances/p/td/tr/tbody/table/divdiv class=aui-message hint shadowed information-macro p class=titleRequired EC2 component options/p span class=aui-icon icon-hintIcon/span
[2/2] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6fa5657f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6fa5657f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6fa5657f Branch: refs/heads/master Commit: 6fa5657fe272c8a705bb037515165bbc713058dd Parents: c68107d Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 15:54:19 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 15:54:19 2015 +0200 -- .../atmosphere/websocket/WebsocketEndpoint.java| 2 +- .../apache/camel/tools/apt/DocumentationHelper.java| 4 .../camel/tools/apt/EndpointAnnotationProcessor.java | 13 - 3 files changed, 13 insertions(+), 6 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/6fa5657f/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java -- diff --git a/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java b/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java index 77a6306..24d8dcf 100644 --- a/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java +++ b/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java @@ -34,7 +34,7 @@ import org.apache.commons.httpclient.params.HttpClientParams; /** * */ -@UriEndpoint(scheme = atmosphere-websocket, extendsScheme = websocket, title = Atmosphere Websocket, +@UriEndpoint(scheme = atmosphere-websocket, extendsScheme = servlet, title = Atmosphere Websocket, syntax = atmosphere-websocket:servicePath, consumerClass = WebsocketConsumer.class, label = websocket) public class WebsocketEndpoint extends ServletEndpoint { http://git-wip-us.apache.org/repos/asf/camel/blob/6fa5657f/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java -- diff --git a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java index e8e8cf7..f354f38 100644 --- a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java +++ b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java @@ -96,8 +96,12 @@ public final class DocumentationHelper { if (file.equals(extendsScheme)) { return new File(../../camel-core/target/classes/org/apache/camel/component/file/file.json); +} else if (ahc.equals(extendsScheme)) { +return new File(../camel-ahc/target/classes/org/apache/camel/component/ahc/ahc.json); } else if (atom.equals(extendsScheme)) { return new File(../camel-atom/target/classes/org/apache/camel/component/atom/atom.json); +} else if (jms.equals(extendsScheme)) { +return new File(../camel-jms/target/classes/org/apache/camel/component/jms/jms.json); } else if (http.equals(extendsScheme)) { return new File(../camel-http/target/classes/org/apache/camel/component/http/http.json); } else if (https.equals(extendsScheme)) { http://git-wip-us.apache.org/repos/asf/camel/blob/6fa5657f/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java -- diff --git a/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java b/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java index 1531971..968213a5 100644 --- a/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java +++ b/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java @@ -75,6 +75,7 @@ public class EndpointAnnotationProcessor extends AbstractAnnotationProcessor { final UriEndpoint uriEndpoint = classElement.getAnnotation(UriEndpoint.class); if (uriEndpoint != null) { String scheme = uriEndpoint.scheme(); +String extendsScheme = uriEndpoint.extendsScheme(); String title = uriEndpoint.title(); final String label = uriEndpoint.label(); if (!isNullOrEmpty(scheme)) { @@ -82,8 +83,10 @@ public class EndpointAnnotationProcessor extends AbstractAnnotationProcessor { // for example camel-mail has a bunch of component schema names that does that String[]
[1/2] camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 6fa5657fe - 350113734 Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d486ee80 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d486ee80 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d486ee80 Branch: refs/heads/master Commit: d486ee8051c2e450178b83126ed48a86f0ba5e6a Parents: 6fa5657 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 15:58:42 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 15:58:42 2015 +0200 -- .../camel/component/gae/auth/GAuthComponent.java | 13 + 1 file changed, 13 insertions(+) -- http://git-wip-us.apache.org/repos/asf/camel/blob/d486ee80/components/camel-gae/src/main/java/org/apache/camel/component/gae/auth/GAuthComponent.java -- diff --git a/components/camel-gae/src/main/java/org/apache/camel/component/gae/auth/GAuthComponent.java b/components/camel-gae/src/main/java/org/apache/camel/component/gae/auth/GAuthComponent.java index d140b3b..90b6280 100644 --- a/components/camel-gae/src/main/java/org/apache/camel/component/gae/auth/GAuthComponent.java +++ b/components/camel-gae/src/main/java/org/apache/camel/component/gae/auth/GAuthComponent.java @@ -51,6 +51,10 @@ public class GAuthComponent extends UriEndpointComponent { return consumerKey; } +/** + * Domain identifying the web application. This is the domain used when registering the application with Google. + * Example: camelcloud.appspot.com. For a non-registered application use anonymous. + */ public void setConsumerKey(String consumerKey) { this.consumerKey = consumerKey; } @@ -59,6 +63,10 @@ public class GAuthComponent extends UriEndpointComponent { return consumerSecret; } +/** + * Consumer secret of the web application. The consumer secret is generated when when registering the application with Google. + * It is needed if the HMAC-SHA1 signature method shall be used. For a non-registered application use anonymous. + */ public void setConsumerSecret(String consumerSecret) { this.consumerSecret = consumerSecret; } @@ -67,6 +75,11 @@ public class GAuthComponent extends UriEndpointComponent { return keyLoader; } +/** + * To configure a key loader to use. + * Part of camel-gae are two key loaders: GAuthPk8Loader for loading a private key from a PKCS#8 file and GAuthJksLoader to load a private key from a Java key store. + * It is needed if the RSA-SHA1 signature method shall be used. These classes are defined in the org.apache.camel.component.gae.auth package. + */ public void setKeyLoader(GAuthKeyLoader keyLoader) { this.keyLoader = keyLoader; }
svn commit: r954798 - in /websites/production/camel/content: cache/main.pageCache camel-2160-release.html
Author: buildbot Date: Sun Jun 14 12:19:41 2015 New Revision: 954798 Log: Production update by buildbot for camel Modified: websites/production/camel/content/cache/main.pageCache websites/production/camel/content/camel-2160-release.html Modified: websites/production/camel/content/cache/main.pageCache == Binary files - no diff available. Modified: websites/production/camel/content/camel-2160-release.html == --- websites/production/camel/content/camel-2160-release.html (original) +++ websites/production/camel/content/camel-2160-release.html Sun Jun 14 12:19:41 2015 @@ -84,7 +84,7 @@ tbody tr td valign=top width=100% -div class=wiki-content maincontenth1 id=Camel2.16.0Release-Camel2.16.0release(currentlyinprogress)Camel 2.16.0#160;release (currently in progress)/h1div style=padding-right:20px;float:left;margin-left:-20px;pimg class=confluence-embedded-image confluence-external-resource src=http://camel.apache.org/download.data/camel-box-v1.0-150x200.png; data-image-src=http://camel.apache.org/download.data/camel-box-v1.0-150x200.png;/p/divdiv style=min-height:200px#160;/divh2 id=Camel2.16.0Release-NewandNoteworthyNew and Noteworthy/h2pWelcome to the 2.16.0 release which approx XXX issues resolved (new features, improvements and bug fixes such as...)/ppNoteworthy improvements:/pulliThe route models (definition classes) preserve property placeholders, which allows round trip editing, and also prevents showing potential sensitive information/liliAdded onPrepareFailure option to#160;a shape=rect href=dead-letter-channel.htmlDead Letter Ch annel/a to allow a custom processor to prepare the Exchange before sending to the dead letter queue./lilia shape=rect href=mongodb.htmlMongoDB/a tailable consumers now allow setting the codereadPreference/code option./liliUsing setFaultBody / setFaultHeader behaves similar to setBody / setHeader to preserve existing headers/attachments by setting on existing IN or OUT message./liliJava DSL using choice with end vs endChoice now validates you use them as intended. Any misconfiguration now throws an exception explaining the problem./lilia shape=rect href=pojo-producing.htmlPOJO Producing/a and#160;a shape=rect href=pojo-consuming.htmlPOJO Consuming/a lifecycle is now in sync with a shape=rect href=camelcontext.htmlCamelContext/a#160;which ensures it works as similar to Camel#160;a shape=rect href=routes.htmlRoutes/a does. Also the created producer/consumer is stopped when#160;a shape=rect href=camelcontext.htmlCam elContext/a#160;is stopping to cleanup properly./lilia shape=rect href=jms.htmlJMS/a#160;component now allows configuring concurrentConsumers/maxConcurrentConsumers separately between from(jms) vs to(jms) using request/reply over JMS/lilispana shape=rect class=external-link href=https://issues.apache.org/jira/browse/CAMEL-8506;Added SEARCH/a operation to Elasticsearch component/span/lilispanThe#160;a shape=rect href=properties.htmlProperties/a component (property placeholder) now supports an encoding option to allow reading the .properties files using a specific charset such as UTF-8. By default ISO-8859-1 is used (latin1)/span/lilispanAdded#160;codereceviveBufferSize/code option to the a shape=rect href=ftp.htmlFTP/a#160;component to make download faster. The size is by default 32kb buffer./span/lilispanThe#160;a shape=rect href=aggregator2.htmlAggregator2/a EIP now allows an external source usin g a#160;codeAggregateController/code to control the aggregator, such as for forcing completing a group or all groups, or query runtime information from the aggregator. A default controller is provided out of the box if none has been configured./span/lilispanThe#160;a shape=rect href=aggregator2.htmlAggregator2/a now enlists in JMX using a#160;codeManagedAggregateProcessorMBean/code which has more information, and also allows using the aggregate controller to control it./span/lilispanThe#160;a shape=rect href=aggregator2.htmlAggregator2/a now includes more runtime statistics which can be accessed from Java and JMX about number of incoming and completed exchanges, and per different completion triggers./span/lilispanThe#160;a shape=rect href=aggregator2.htmlAggregator2/a now supports pre-completion mode if the aggregation strategy implements#160;codePreCompletionAwareAggregationStrategy/code. This supports the use-case w here an incoming Exchange are used to determine if the current aggregated group is completed or not. If completed the group is emitted as-is, and the new incoming Exchange is used to start a new group from scratch./span/lilispanAdded options to#160;a shape=rect href=mail.htmlMail/a consumer so it can skip or handle a mail message that cannot be read from the mail server in the batch; and then move on to read the
[1/2] camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 62428565a - 12e0ce4c0 Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/827bcf5c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/827bcf5c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/827bcf5c Branch: refs/heads/master Commit: 827bcf5cfefb2fc116cde018777ac1dc0ff508a8 Parents: 6242856 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 13:12:29 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 15:22:19 2015 +0200 -- .../main/java/org/apache/camel/tools/apt/DocumentationHelper.java | 2 ++ 1 file changed, 2 insertions(+) -- http://git-wip-us.apache.org/repos/asf/camel/blob/827bcf5c/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java -- diff --git a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java index 87eaee3..916e0e3 100644 --- a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java +++ b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java @@ -96,6 +96,8 @@ public final class DocumentationHelper { if (file.equals(extendsScheme)) { return new File(../../camel-core/target/classes/org/apache/camel/component/file/file.json); +} else if (atom.equals(extendsScheme)) { +return new File(../camel-atom/target/classes/org/apache/camel/component/atom/atom.json); } else if (http.equals(extendsScheme)) { return new File(../camel-http/target/classes/org/apache/camel/component/http/http.json); } else if (https.equals(extendsScheme)) {
[3/5] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1e1e1f9f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1e1e1f9f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1e1e1f9f Branch: refs/heads/master Commit: 1e1e1f9f69269ed4fdaa40a153871c8780bda219 Parents: be75520 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 10:06:38 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 13:08:07 2015 +0200 -- .../camel/tools/apt/DocumentationHelper.java| 52 +++- .../tools/apt/EndpointAnnotationProcessor.java | 2 +- .../camel/tools/apt/JsonSchemaHelper.java | 89 3 files changed, 141 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/1e1e1f9f/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java -- diff --git a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java index 93a7ae5..37e190b 100644 --- a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java +++ b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java @@ -17,17 +17,67 @@ package org.apache.camel.tools.apt; import java.io.BufferedReader; +import java.io.File; +import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.LineNumberReader; +import java.util.List; +import java.util.Map; + +import static org.apache.camel.tools.apt.JsonSchemaHelper.parseJsonSchema; /** * Helper to find documentation for inherited options when a component extends another. */ public final class DocumentationHelper { -public static String findJavaDoc(String scheme, String fieldName) { +public static String findJavaDoc(String scheme, String extendsScheme, String fieldName) { +File file = jsonFile(scheme, extendsScheme); +if (file != null) { +FileInputStream fis = null; +try { +fis = new FileInputStream(file); +String json = loadText(fis); +ListMapString, String rows = parseJsonSchema(properties, json, true); + +for (MapString, String row : rows) { +String name = row.get(name); +String description = row.get(description); +if (fieldName.equals(name)) { +return description; +} +} +} catch (Exception e) { +// ignore +} finally { +IOHelper.close(fis); +} +} + +// not found +return null; +} + +private static File jsonFile(String scheme, String extendsScheme) { +// TODO: scan components for each component and find component name from extendsScheme +// and then find the package name where the json file is + +if (file.equals(extendsScheme)) { +return new File(../../camel-core/target/classes/org/apache/camel/component/file/file.json); +} else if (http.equals(extendsScheme)) { +return new File(../camel-http/target/classes/org/apache/camel/component/http/http.json); +} else if (https.equals(extendsScheme)) { +return new File(../camel-http/target/classes/org/apache/camel/component/http/https.json); +} else if (netty.equals(extendsScheme)) { +return new File(../camel-netty/target/classes/org/apache/camel/component/netty/netty.json); +} else if (netty4.equals(extendsScheme)) { +return new File(../camel-netty4/target/classes/org/apache/camel/component/netty4/netty4.json); +} else if (servlet.equals(extendsScheme)) { +return new File(../camel-servlet/target/classes/org/apache/camel/component/servlet/servlet.json); +} +// not found return null; } http://git-wip-us.apache.org/repos/asf/camel/blob/1e1e1f9f/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java -- diff --git a/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java b/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java index 6cb7973..7f895ed 100644 --- a/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java +++ b/tooling/apt/src/main/java/org/apache/camel/tools/apt/EndpointAnnotationProcessor.java @@ -286,7 +286,7 @@ public class EndpointAnnotationProcessor
[3/3] camel git commit: Fixed CS
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/359bf0e4 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/359bf0e4 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/359bf0e4 Branch: refs/heads/master Commit: 359bf0e45a7eef2efdc2d8ad6f275233bef23777 Parents: 2acb2a0 Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 13:42:36 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 13:42:36 2015 +0200 -- .../camel/component/hazelcast/queue/HazelcastQueueProducer.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/359bf0e4/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java -- diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java index 4575439..c814e3c 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java @@ -115,6 +115,6 @@ public class HazelcastQueueProducer extends HazelcastDefaultProducer { } private void remainingCapacity(Exchange exchange) { - exchange.getOut().setBody(this.queue.remainingCapacity()); +exchange.getOut().setBody(this.queue.remainingCapacity()); } } \ No newline at end of file
[2/3] camel git commit: CAMEL-8868 Add remainingCapacity operation to HazelcastComponentHelper mapping
CAMEL-8868 Add remainingCapacity operation to HazelcastComponentHelper mapping Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2acb2a05 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2acb2a05 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2acb2a05 Branch: refs/heads/master Commit: 2acb2a05fd6ff2d0ee8aca1d09a18d3b67d0b684 Parents: a8f71ae Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 13:33:26 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 13:33:26 2015 +0200 -- .../apache/camel/component/hazelcast/HazelcastComponentHelper.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/camel/blob/2acb2a05/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java -- diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java index b1b876d..448bc56 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java @@ -116,6 +116,7 @@ public final class HazelcastComponentHelper { addMapping(offer, HazelcastConstants.OFFER_OPERATION); addMapping(peek, HazelcastConstants.PEEK_OPERATION); addMapping(poll, HazelcastConstants.POLL_OPERATION); +addMapping(remainingCapacity, HazelcastConstants.REMAINING_CAPACITY_OPERATION); // topic addMapping(publish, HazelcastConstants.PUBLISH_OPERATION);
[1/5] camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 722a588e7 - e20ae861b Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/be755208 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/be755208 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/be755208 Branch: refs/heads/master Commit: be7552085c875dc8871ce5f39c61e615163ef185 Parents: 722a588 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 09:46:35 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 13:08:06 2015 +0200 -- .../camel/component/ahc/ws/WsEndpoint.java | 3 +- .../camel/component/amqp/AMQPEndpoint.java | 3 +- .../atmosphere/websocket/WebsocketEndpoint.java | 3 +- .../component/file/remote/FtpEndpoint.java | 3 +- .../component/file/remote/FtpsEndpoint.java | 3 +- .../component/file/remote/SftpEndpoint.java | 3 +- .../camel/component/gae/http/GHttpEndpoint.java | 3 +- .../camel/component/gae/task/GTaskEndpoint.java | 3 +- .../component/jetty8/JettyHttpEndpoint8.java| 3 +- .../component/jetty9/JettyHttpEndpoint9.java| 3 +- .../apache/camel/component/scp/ScpEndpoint.java | 3 +- .../component/netty/http/NettyHttpEndpoint.java | 3 +- .../netty4/http/NettyHttpEndpoint.java | 3 +- .../apache/camel/component/rss/RssEndpoint.java | 3 +- .../component/servlet/ServletEndpoint.java | 3 +- .../camel/tools/apt/DocumentationHelper.java| 63 .../tools/apt/EndpointAnnotationProcessor.java | 16 + .../java/org/apache/camel/spi/UriEndpoint.java | 11 18 files changed, 120 insertions(+), 15 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/be755208/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java -- diff --git a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java index ec37304..e0d0b88 100644 --- a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java +++ b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java @@ -38,7 +38,8 @@ import org.apache.camel.spi.UriParam; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -@UriEndpoint(scheme = ahc-ws,ahc-wss, title = AHC Websocket,AHC Secure Websocket, syntax = ahc-ws:httpUri, consumerClass = WsConsumer.class, label = websocket) +@UriEndpoint(scheme = ahc-ws,ahc-wss, extendsScheme = ahc,ahc, title = AHC Websocket,AHC Secure Websocket, +syntax = ahc-ws:httpUri, consumerClass = WsConsumer.class, label = websocket) public class WsEndpoint extends AhcEndpoint { private static final transient Logger LOG = LoggerFactory.getLogger(WsEndpoint.class); http://git-wip-us.apache.org/repos/asf/camel/blob/be755208/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPEndpoint.java -- diff --git a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPEndpoint.java b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPEndpoint.java index 109a393..ce630f6 100644 --- a/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPEndpoint.java +++ b/components/camel-amqp/src/main/java/org/apache/camel/component/amqp/AMQPEndpoint.java @@ -20,7 +20,8 @@ import org.apache.camel.component.jms.JmsConsumer; import org.apache.camel.component.jms.JmsEndpoint; import org.apache.camel.spi.UriEndpoint; -@UriEndpoint(scheme = amqp, title = AMQP, syntax = amqp:destinationType:destinationName, consumerClass = JmsConsumer.class, label = messaging) +@UriEndpoint(scheme = amqp, extendsScheme = jms, title = AMQP, +syntax = amqp:destinationType:destinationName, consumerClass = JmsConsumer.class, label = messaging) public class AMQPEndpoint extends JmsEndpoint { } http://git-wip-us.apache.org/repos/asf/camel/blob/be755208/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java -- diff --git a/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java b/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java index 9b5abe8..77a6306 100644 --- a/components/camel-atmosphere-websocket/src/main/java/org/apache/camel/component/atmosphere/websocket/WebsocketEndpoint.java +++
[4/5] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a4e69971 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a4e69971 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a4e69971 Branch: refs/heads/master Commit: a4e69971dfb8e32f421da5908bdc1cf3528a0043 Parents: 08c850e Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 11:28:11 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 13:08:08 2015 +0200 -- .../file/remote/SftpConfiguration.java | 47 ++- .../camel/component/http/HttpEndpoint.java | 29 +--- .../camel/component/scp/ScpConfiguration.java | 22 - .../component/servlet/ServletComponent.java | 6 +++ .../component/servlet/ServletEndpoint.java | 2 +- .../camel/tools/apt/DocumentationHelper.java| 48 .../tools/apt/EndpointAnnotationProcessor.java | 24 -- 7 files changed, 153 insertions(+), 25 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/a4e69971/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpConfiguration.java -- diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpConfiguration.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpConfiguration.java index f7b21e8..ac24e7c 100644 --- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpConfiguration.java +++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpConfiguration.java @@ -43,7 +43,7 @@ public class SftpConfiguration extends RemoteFileConfiguration { @UriParam private String privateKeyPassphrase; private KeyPair keyPair; -@UriParam(defaultValue = no) +@UriParam(defaultValue = no, enums = no,yes) private String strictHostKeyChecking = no; @UriParam private int serverAliveInterval; @@ -77,6 +77,9 @@ public class SftpConfiguration extends RemoteFileConfiguration { return knownHostsFile; } +/** + * Sets the known_hosts file, so that the SFTP endpoint can do host key verification. + */ public void setKnownHostsFile(String knownHostsFile) { this.knownHostsFile = knownHostsFile; } @@ -85,6 +88,9 @@ public class SftpConfiguration extends RemoteFileConfiguration { return knownHostsUri; } +/** + * Sets the known_hosts file (loaded from classpath by default), so that the SFTP endpoint can do host key verification. + */ public void setKnownHostsUri(String knownHostsUri) { this.knownHostsUri = knownHostsUri; } @@ -101,6 +107,9 @@ public class SftpConfiguration extends RemoteFileConfiguration { return privateKeyFile; } +/** + * Set the private key file to that the SFTP endpoint can do private key verification. + */ public void setPrivateKeyFile(String privateKeyFile) { this.privateKeyFile = privateKeyFile; } @@ -109,6 +118,9 @@ public class SftpConfiguration extends RemoteFileConfiguration { return privateKeyUri; } +/** + * Set the private key file (loaded from classpath by default) to that the SFTP endpoint can do private key verification. + */ public void setPrivateKeyUri(String privateKeyUri) { this.privateKeyUri = privateKeyUri; } @@ -117,6 +129,9 @@ public class SftpConfiguration extends RemoteFileConfiguration { return privateKey; } +/** + * Set the private key as byte[] to that the SFTP endpoint can do private key verification. + */ public void setPrivateKey(byte[] privateKey) { this.privateKey = privateKey; } @@ -125,6 +140,9 @@ public class SftpConfiguration extends RemoteFileConfiguration { return privateKeyPassphrase; } +/** + * Set the private key file passphrase to that the SFTP endpoint can do private key verification. + */ public void setPrivateKeyPassphrase(String privateKeyFilePassphrase) { this.privateKeyPassphrase = privateKeyFilePassphrase; } @@ -151,10 +169,16 @@ public class SftpConfiguration extends RemoteFileConfiguration { return strictHostKeyChecking; } +/** + * Sets whether to use strict host key checking. + */ public void setStrictHostKeyChecking(String strictHostKeyChecking) { this.strictHostKeyChecking = strictHostKeyChecking; } +/** + * Allows you to set the serverAliveInterval of the sftp session + */ public void setServerAliveInterval(int serverAliveInterval) { this.serverAliveInterval = serverAliveInterval; }
[1/3] camel git commit: CAMEL-8868 Camel-Hazelcast: Add remainingCapacity operation to queue
Repository: camel Updated Branches: refs/heads/master e20ae861b - 359bf0e45 CAMEL-8868 Camel-Hazelcast: Add remainingCapacity operation to queue Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a8f71ae3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a8f71ae3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a8f71ae3 Branch: refs/heads/master Commit: a8f71ae32366087d6e8e5cdc559eaa9d04cec786 Parents: e20ae86 Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 13:30:13 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 13:30:42 2015 +0200 -- .../camel/component/hazelcast/HazelcastConstants.java| 3 ++- .../hazelcast/queue/HazelcastQueueProducer.java | 8 .../component/hazelcast/HazelcastQueueProducerTest.java | 11 +++ 3 files changed, 21 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/a8f71ae3/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java -- diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java index fcc7256..11c775e 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java @@ -83,9 +83,10 @@ public final class HazelcastConstants { public static final int OFFER_OPERATION = 32; public static final int PEEK_OPERATION = 33; public static final int POLL_OPERATION = 34; +public static final int REMAINING_CAPACITY_OPERATION = 35; // topic -public static final int PUBLISH_OPERATION = 35; +public static final int PUBLISH_OPERATION = 36; /* * header values http://git-wip-us.apache.org/repos/asf/camel/blob/a8f71ae3/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java -- diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java index 46c7488..4575439 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java @@ -69,6 +69,10 @@ public class HazelcastQueueProducer extends HazelcastDefaultProducer { this.remove(exchange); break; +case HazelcastConstants.REMAINING_CAPACITY_OPERATION: +this.remainingCapacity(exchange); +break; + default: throw new IllegalArgumentException(String.format(The value '%s' is not allowed for parameter '%s' on the QUEUE cache., operation, HazelcastConstants.OPERATION)); } @@ -109,4 +113,8 @@ public class HazelcastQueueProducer extends HazelcastDefaultProducer { this.queue.remove(); } } + +private void remainingCapacity(Exchange exchange) { + exchange.getOut().setBody(this.queue.remainingCapacity()); +} } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/a8f71ae3/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java -- diff --git a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java index 76e47ef..3807e98 100644 --- a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java +++ b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java @@ -114,6 +114,14 @@ public class HazelcastQueueProducerTest extends HazelcastCamelTestSupport { verify(queue).peek(); assertEquals(foo, answer); } + +@Test +public void remainingCapacity() throws InterruptedException { +when(queue.remainingCapacity()).thenReturn(10); +int answer = template.requestBody(direct:remainingCapacity, null, Integer.class); +verify(queue).remainingCapacity(); +assertEquals(10,
[2/2] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/12e0ce4c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/12e0ce4c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/12e0ce4c Branch: refs/heads/master Commit: 12e0ce4c0f79486faa3adc8e93af160a73375bf8 Parents: 827bcf5 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 13:56:57 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 15:22:20 2015 +0200 -- .../java/org/apache/camel/tools/apt/DocumentationHelper.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/12e0ce4c/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java -- diff --git a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java index 916e0e3..e8e8cf7 100644 --- a/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java +++ b/tooling/apt/src/main/java/org/apache/camel/tools/apt/DocumentationHelper.java @@ -91,8 +91,8 @@ public final class DocumentationHelper { } private static File jsonFile(String scheme, String extendsScheme) { -// TODO: scan components for each component and find component name from extendsScheme -// and then find the package name where the json file is +// we cannot use classloader to load external resources from other JARs during apt plugin, +// so load these resources using the file system if (file.equals(extendsScheme)) { return new File(../../camel-core/target/classes/org/apache/camel/component/file/file.json);
camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 350113734 - 63df40219 Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/63df4021 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/63df4021 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/63df4021 Branch: refs/heads/master Commit: 63df40219884d134f83ea9c65901ce96726c4430 Parents: 3501137 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 16:11:04 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 16:11:04 2015 +0200 -- .../camel/component/file/remote/SftpEndpoint.java | 16 1 file changed, 12 insertions(+), 4 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/63df4021/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpEndpoint.java -- diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpEndpoint.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpEndpoint.java index b8f8db3..5547376 100644 --- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpEndpoint.java +++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/SftpEndpoint.java @@ -34,7 +34,7 @@ public class SftpEndpoint extends RemoteFileEndpointChannelSftp.LsEntry { @UriParam protected SftpConfiguration configuration; @UriParam -Proxy proxy; +protected Proxy proxy; public SftpEndpoint() { } @@ -74,12 +74,20 @@ public class SftpEndpoint extends RemoteFileEndpointChannelSftp.LsEntry { return operations; } -@Override -public String getScheme() { -return sftp; +public Proxy getProxy() { +return proxy; } +/** + * To use a custom configured com.jcraft.jsch.Proxy. + * This proxy is used to consume/send messages from the target SFTP host. + */ public void setProxy(Proxy proxy) { this.proxy = proxy; } + +@Override +public String getScheme() { +return sftp; +} }
[2/2] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/35011373 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/35011373 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/35011373 Branch: refs/heads/master Commit: 350113734a8418853d527f78845ba9e67d970ac1 Parents: d486ee8 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 16:08:23 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 16:08:23 2015 +0200 -- .../camel/component/scp/ScpConfiguration.java | 56 +--- .../camel/tools/apt/DocumentationHelper.java| 2 + 2 files changed, 16 insertions(+), 42 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/35011373/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpConfiguration.java -- diff --git a/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpConfiguration.java b/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpConfiguration.java index d4292d0..1cfb5e9 100644 --- a/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpConfiguration.java +++ b/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpConfiguration.java @@ -32,8 +32,6 @@ public class ScpConfiguration extends RemoteFileConfiguration { public static final String DEFAULT_MOD = 664; @UriParam(defaultValue = true) private boolean useUserKnownHostsFile = true; -@UriParam(defaultValue = true) -private boolean verboseLogging = true; @UriParam private String knownHostsFile; @UriParam @@ -42,18 +40,12 @@ public class ScpConfiguration extends RemoteFileConfiguration { private String privateKeyFilePassphrase; @UriParam(enums = no,yes, defaultValue = no) private String strictHostKeyChecking; -@UriParam -private int serverAliveInterval; -@UriParam(defaultValue = 1) -private int serverAliveCountMax = 1; @UriParam(defaultValue = DEFAULT_MOD) private String chmod = DEFAULT_MOD; // comma separated list of ciphers. // null means default jsch list will be used @UriParam private String ciphers; -@UriParam -private int compression; public ScpConfiguration() { setProtocol(scp); @@ -72,6 +64,9 @@ public class ScpConfiguration extends RemoteFileConfiguration { return knownHostsFile; } +/** + * Sets the known_hosts file, so that the jsch endpoint can do host key verification. + */ public void setKnownHostsFile(String knownHostsFile) { this.knownHostsFile = knownHostsFile; } @@ -91,6 +86,9 @@ public class ScpConfiguration extends RemoteFileConfiguration { return privateKeyFile; } +/** + * Set the private key file to that the SFTP endpoint can do private key verification. + */ public void setPrivateKeyFile(String privateKeyFile) { this.privateKeyFile = privateKeyFile; } @@ -99,6 +97,9 @@ public class ScpConfiguration extends RemoteFileConfiguration { return privateKeyFilePassphrase; } +/** + * Set the private key file passphrase to that the SFTP endpoint can do private key verification. + */ public void setPrivateKeyFilePassphrase(String privateKeyFilePassphrase) { this.privateKeyFilePassphrase = privateKeyFilePassphrase; } @@ -114,22 +115,6 @@ public class ScpConfiguration extends RemoteFileConfiguration { this.strictHostKeyChecking = strictHostKeyChecking; } -public void setServerAliveInterval(int serverAliveInterval) { -this.serverAliveInterval = serverAliveInterval; -} - -public int getServerAliveInterval() { -return serverAliveInterval; -} - -public void setServerAliveCountMax(int serverAliveCountMax) { -this.serverAliveCountMax = serverAliveCountMax; -} - -public int getServerAliveCountMax() { -return serverAliveCountMax; -} - /** * Allows you to set chmod on the stored file. For example chmod=664. */ @@ -152,6 +137,11 @@ public class ScpConfiguration extends RemoteFileConfiguration { return chmod; } +/** + * Set a comma separated list of ciphers that will be used in order of preference. + * Possible cipher names are defined by JCraft JSCH. Some examples include: aes128-ctr,aes128-cbc,3des-ctr,3des-cbc,blowfish-cbc,aes192-cbc,aes256-cbc. + * If not specified the default list from JSCH will be used. + */ public void setCiphers(String ciphers) { this.ciphers = ciphers; } @@ -160,22 +150,4 @@ public class ScpConfiguration extends RemoteFileConfiguration { return ciphers;
[1/2] camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 12e0ce4c0 - 6fa5657fe Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c68107d3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c68107d3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c68107d3 Branch: refs/heads/master Commit: c68107d3b1829fcf4d43ce93504cfd30fa320b8c Parents: 12e0ce4 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 15:41:34 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 15:41:34 2015 +0200 -- .../camel/component/gae/mail/GMailEndpoint.java | 14 +- .../component/gae/task/GTaskComponent.java | 11 - .../camel/component/gae/task/GTaskEndpoint.java | 47 +++- .../camel/component/http/HttpEndpoint.java | 24 +- 4 files changed, 72 insertions(+), 24 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/c68107d3/components/camel-gae/src/main/java/org/apache/camel/component/gae/mail/GMailEndpoint.java -- diff --git a/components/camel-gae/src/main/java/org/apache/camel/component/gae/mail/GMailEndpoint.java b/components/camel-gae/src/main/java/org/apache/camel/component/gae/mail/GMailEndpoint.java index 93e25a8..1562601 100644 --- a/components/camel-gae/src/main/java/org/apache/camel/component/gae/mail/GMailEndpoint.java +++ b/components/camel-gae/src/main/java/org/apache/camel/component/gae/mail/GMailEndpoint.java @@ -40,7 +40,7 @@ public class GMailEndpoint extends DefaultEndpoint implements OutboundBindingSup private OutboundBindingGMailEndpoint, Message, Void outboundBinding; private MailService mailService; -@UriPath @Metadata(required = true) +@UriPath(description = The email of the sender) @Metadata(required = true) private String sender; @UriParam private String subject; @@ -77,6 +77,9 @@ public class GMailEndpoint extends DefaultEndpoint implements OutboundBindingSup return subject; } +/** + * Subject of the email. + */ public void setSubject(String subject) { this.subject = subject; } @@ -85,6 +88,9 @@ public class GMailEndpoint extends DefaultEndpoint implements OutboundBindingSup return to; } +/** + * To-receiver of the email. This can be a single receiver or a comma-separated list of receivers. + */ public void setTo(String to) { this.to = to; } @@ -93,6 +99,9 @@ public class GMailEndpoint extends DefaultEndpoint implements OutboundBindingSup return cc; } +/** + * Cc-receiver of the email. This can be a single receiver or a comma-separated list of receivers. + */ public void setCc(String cc) { this.cc = cc; } @@ -101,6 +110,9 @@ public class GMailEndpoint extends DefaultEndpoint implements OutboundBindingSup return bcc; } +/** + * Bcc-receiver of the email. This can be a single receiver or a comma-separated list of receivers. + */ public void setBcc(String bcc) { this.bcc = bcc; } http://git-wip-us.apache.org/repos/asf/camel/blob/c68107d3/components/camel-gae/src/main/java/org/apache/camel/component/gae/task/GTaskComponent.java -- diff --git a/components/camel-gae/src/main/java/org/apache/camel/component/gae/task/GTaskComponent.java b/components/camel-gae/src/main/java/org/apache/camel/component/gae/task/GTaskComponent.java index 8049806..d248d5d 100644 --- a/components/camel-gae/src/main/java/org/apache/camel/component/gae/task/GTaskComponent.java +++ b/components/camel-gae/src/main/java/org/apache/camel/component/gae/task/GTaskComponent.java @@ -44,6 +44,7 @@ import org.apache.commons.httpclient.params.HttpClientParams; * for installing a web hook. */ public class GTaskComponent extends ServletComponent { + public GTaskComponent() { super(GTaskEndpoint.class); } @@ -51,23 +52,29 @@ public class GTaskComponent extends ServletComponent { @Override @SuppressWarnings(unchecked) protected Endpoint createEndpoint(String uri, String remaining, MapString, Object parameters) throws Exception { -String workerRoot = getAndRemoveParameter( -parameters, workerRoot, String.class, worker); +String workerRoot = getAndRemoveParameter(parameters, workerRoot, String.class, worker); +String inboundBindingRef = (String) parameters.get(inboundBindingRef); +String outboundBindingRef = (String) parameters.get(outboundBindingRef); + OutboundBindingGTaskEndpoint, TaskOptions, Void outboundBinding = resolveAndRemoveReferenceParameter(
[2/3] camel git commit: Upgrade rx
Upgrade rx Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5522312c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5522312c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5522312c Branch: refs/heads/master Commit: 5522312cb38dac2e877fbdee6085755bfa85d85b Parents: 48c6c4c Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 08:48:56 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 08:59:20 2015 +0200 -- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/5522312c/parent/pom.xml -- diff --git a/parent/pom.xml b/parent/pom.xml index 29030e5..a05a0eb 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -410,7 +410,7 @@ rhino-version1.7R2/rhino-version rome-bundle-version1.0_3/rome-bundle-version rome-version1.0/rome-version -rxjava-version1.0.10/rxjava-version +rxjava-version1.0.12/rxjava-version saaj-impl-version1.3.2_2/saaj-impl-version saxon-bundle-version9.5.1-5_1/saxon-bundle-version saxon-version9.5.1-5/saxon-version
[1/3] camel git commit: CAMEL-8865 Removal of version from url in web based examples
Repository: camel Updated Branches: refs/heads/camel-2.15.x e82251b7d - f2fedc76a refs/heads/master e47aa24a7 - 5522312cb CAMEL-8865 Removal of version from url in web based examples Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/48c6c4c8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/48c6c4c8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/48c6c4c8 Branch: refs/heads/master Commit: 48c6c4c8958a36c26e8417c92834d18776d0e180 Parents: e47aa24 Author: Andrew Block andy.bl...@gmail.com Authored: Sat Jun 13 23:39:14 2015 -0500 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 08:59:19 2015 +0200 -- examples/camel-example-servlet-rest-tomcat/pom.xml | 3 +++ .../src/main/webapp/home.html | 3 +-- .../camel-example-servlet-tomcat-no-spring/README.txt | 8 examples/camel-example-servlet-tomcat-no-spring/pom.xml | 7 ++- .../apache/camel/example/servletlistener/HelloBean.java | 4 ++-- examples/camel-example-servlet-tomcat/README.txt| 8 examples/camel-example-servlet-tomcat/pom.xml | 12 ++-- .../src/main/resources/camel-config.xml | 2 +- examples/camel-example-spark-rest-tomcat/README.txt | 4 ++-- examples/camel-example-spark-rest-tomcat/pom.xml| 9 + examples/camel-example-spring-boot/README.txt | 2 +- examples/camel-example-spring-boot/pom.xml | 4 12 files changed, 47 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/48c6c4c8/examples/camel-example-servlet-rest-tomcat/pom.xml -- diff --git a/examples/camel-example-servlet-rest-tomcat/pom.xml b/examples/camel-example-servlet-rest-tomcat/pom.xml index a30aa05..09c8f11 100755 --- a/examples/camel-example-servlet-rest-tomcat/pom.xml +++ b/examples/camel-example-servlet-rest-tomcat/pom.xml @@ -198,6 +198,9 @@ version${jetty9-version}/version configuration webAppSourceDirectorytarget/classes/webAppSourceDirectory + webApp + contextPath/${project.artifactId}/contextPath + /webApp /configuration /plugin /plugins http://git-wip-us.apache.org/repos/asf/camel/blob/48c6c4c8/examples/camel-example-servlet-rest-tomcat/src/main/webapp/home.html -- diff --git a/examples/camel-example-servlet-rest-tomcat/src/main/webapp/home.html b/examples/camel-example-servlet-rest-tomcat/src/main/webapp/home.html index d87a0b8..03cb404 100644 --- a/examples/camel-example-servlet-rest-tomcat/src/main/webapp/home.html +++ b/examples/camel-example-servlet-rest-tomcat/src/main/webapp/home.html @@ -79,8 +79,7 @@ /ul p/ -To use the swagger ui, follow this link. Replace the URL value with this one to access the REST local resources (http://localhost:8080/api-docs or (http://localhost:8080/camel-example-servlet-rest-tomcat/api-docs -when deployed in Apache Tomcat) +To use the swagger ui, follow this link. Replace the URL value with this one to access the REST local resources http://localhost:8080/camel-example-servlet-rest-tomcat/api-docs ul lia href=index.htmlswagger/a - swagger ui page/li /ul http://git-wip-us.apache.org/repos/asf/camel/blob/48c6c4c8/examples/camel-example-servlet-tomcat-no-spring/README.txt -- diff --git a/examples/camel-example-servlet-tomcat-no-spring/README.txt b/examples/camel-example-servlet-tomcat-no-spring/README.txt index db3afa5..243ab94 100644 --- a/examples/camel-example-servlet-tomcat-no-spring/README.txt +++ b/examples/camel-example-servlet-tomcat-no-spring/README.txt @@ -11,11 +11,11 @@ To run the example deploy it in Apache Tomcat by copying the .war to the deploy folder of Apache Tomcat. And then hit this url from a webbrowser which has further -instructions (use correct version number) - http://localhost:8080/camel-example-servlet-tomcat-no-spring-{version} +instructions + http://localhost:8080/camel-example-servlet-tomcat-no-spring -The servlet is located at (use correct version number) - http://localhost:8080/camel-example-servlet-tomcat-no-spring-{version}/camel +The servlet is located at + http://localhost:8080/camel-example-servlet-tomcat-no-spring/camel This example is documented at http://camel.apache.org/servlet-tomcat-example-no-spring.html
[3/3] camel git commit: Upgrade rx
Upgrade rx Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f2fedc76 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f2fedc76 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f2fedc76 Branch: refs/heads/camel-2.15.x Commit: f2fedc76a50b632cacb1c00fb0872a29653a4629 Parents: e82251b Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 08:48:56 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 08:59:46 2015 +0200 -- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/f2fedc76/parent/pom.xml -- diff --git a/parent/pom.xml b/parent/pom.xml index 2a81d9f..856f64c 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -399,7 +399,7 @@ rhino-version1.7R2/rhino-version rome-bundle-version1.0_3/rome-bundle-version rome-version1.0/rome-version -rxjava-version1.0.10/rxjava-version +rxjava-version1.0.12/rxjava-version saaj-impl-version1.3.2_2/saaj-impl-version saxon-bundle-version9.5.1-5_1/saxon-bundle-version saxon-version9.5.1-5/saxon-version
svn commit: r954779 [3/4] - in /websites/production/camel/content: book-component-appendix.html book-cookbook.html book-in-one-page.html cache/main.pageCache mock.html
Modified: websites/production/camel/content/book-in-one-page.html == --- websites/production/camel/content/book-in-one-page.html (original) +++ websites/production/camel/content/book-in-one-page.html Sun Jun 14 07:21:15 2015 @@ -2166,54 +2166,18 @@ return new ProcessBuilder(jpaTemplate, t pSo you could query data from various Camel a shape=rect href=components.htmlComponents/a such as a shape=rect href=file2.htmlFile/a, a shape=rect href=http.htmlHTTP/a or a shape=rect href=jpa.htmlJPA/a, perform multiple patterns such as a shape=rect href=splitter.htmlSplitter/a or a shape=rect href=message-translator.htmlMessage Translator/a then send the messages to some other a shape=rect href=component.htmlComponent/a./p pTo show how this all fits together, try the a shape=rect href=etl-example.htmlETL Example/a /p -h2 id=BookInOnePage-MockComponentMock Component/h2 - -a shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a. - -pThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://jmock.org; rel=nofollowjMock/a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected. /p - -pThis allows you to test various things like:/p -ulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a or a shape=rect href=xquery.htmlXQuery/a a shape=rect href=expression.htmlExpression/a./li/ul - - -pstrongNote/strong that there is also the a shape=rect href=test.htmlTest endpoint/a which is a Mock endpoint, but which uses a second endpoint to provide the list of expected message bodies and automatically sets up the Mock endpoint assertions. In other words, it's a Mock endpoint that automatically sets up its assertions from some sample messages in a a shape=rect href=file2.htmlFile/a or a shape=rect href=jpa.htmldatabase/a, for example./p - -div class=aui-message problem shadowed information-macro +h2 id=BookInOnePage-MockComponentMock Component/h2pa shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a./ppThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://www.jmock.org; rel=nofollowjMock/aa shape=rect class=external-link href=http://jmock.org; rel=nofollow /a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected./ppThis allows you to test various things like:/pulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a
svn commit: r954779 [1/4] - in /websites/production/camel/content: book-component-appendix.html book-cookbook.html book-in-one-page.html cache/main.pageCache mock.html
Author: buildbot Date: Sun Jun 14 07:21:15 2015 New Revision: 954779 Log: Production update by buildbot for camel Modified: websites/production/camel/content/book-component-appendix.html websites/production/camel/content/book-cookbook.html websites/production/camel/content/book-in-one-page.html websites/production/camel/content/cache/main.pageCache websites/production/camel/content/mock.html Modified: websites/production/camel/content/book-component-appendix.html == --- websites/production/camel/content/book-component-appendix.html (original) +++ websites/production/camel/content/book-component-appendix.html Sun Jun 14 07:21:15 2015 @@ -1334,11 +1334,11 @@ template.send(quot;direct:alias-verify /div /div pThe strongcxf:/strong component provides integration with a shape=rect href=http://cxf.apache.org;Apache CXF/a for connecting to JAX-WS services hosted in CXF./ppstyle type=text/css/*![CDATA[*/ -div.rbtoc1433834366467 {padding: 0px;} -div.rbtoc1433834366467 ul {list-style: disc;margin-left: 0px;} -div.rbtoc1433834366467 li {margin-left: 0px;padding-left: 0px;} +div.rbtoc1434266378420 {padding: 0px;} +div.rbtoc1434266378420 ul {list-style: disc;margin-left: 0px;} +div.rbtoc1434266378420 li {margin-left: 0px;padding-left: 0px;} -/*]]*//style/pdiv class=toc-macro rbtoc1433834366467 +/*]]*//style/pdiv class=toc-macro rbtoc1434266378420 ul class=toc-indentationlia shape=rect href=#CXF-CXFComponentCXF Component/a ul class=toc-indentationlia shape=rect href=#CXF-URIformatURI format/a/lilia shape=rect href=#CXF-OptionsOptions/a ul class=toc-indentationlia shape=rect href=#CXF-ThedescriptionsofthedataformatsThe descriptions of the dataformats/a @@ -7616,54 +7616,18 @@ assertEquals(quot;Bye Worldquot;, resp lt;/beangt; ]]/script /div/divp/ph3 id=BookComponentAppendix-SeeAlso.40See Also/h3 -ullia shape=rect href=configuring-camel.htmlConfiguring Camel/a/lilia shape=rect href=component.htmlComponent/a/lilia shape=rect href=endpoint.htmlEndpoint/a/lilia shape=rect href=getting-started.htmlGetting Started/a/li/ulul class=alternatelia shape=rect href=mina2.htmlMINA2/a/lilia shape=rect href=netty.htmlNetty/a/li/ul h2 id=BookComponentAppendix-MockComponentMock Component/h2 - -a shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a. - -pThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://jmock.org; rel=nofollowjMock/a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected. /p - -pThis allows you to test various things like:/p -ulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a or a shape=rect href=xquery.htmlXQuery/a a shape=rect href=expression.htmlExpression/a./li/ul - - -pstrongNote/strong that there is also the a shape=rect href=test.htmlTest endpoint/a which is a Mock endpoint, but which uses a second endpoint to provide the list of expected message bodies and automatically sets up the Mock endpoint assertions. In other words, it's a Mock endpoint that automatically sets up its assertions from some sample messages in a a shape=rect href=file2.htmlFile/a or a shape=rect href=jpa.htmldatabase/a, for example./p - -div class=aui-message problem shadowed information-macro +ullia shape=rect href=configuring-camel.htmlConfiguring Camel/a/lilia shape=rect href=component.htmlComponent/a/lilia shape=rect href=endpoint.htmlEndpoint/a/lilia shape=rect href=getting-started.htmlGetting Started/a/li/ulul class=alternatelia shape=rect href=mina2.htmlMINA2/a/lilia shape=rect href=netty.htmlNetty/a/li/ul h2 id=BookComponentAppendix-MockComponentMock
svn commit: r954779 [2/4] - in /websites/production/camel/content: book-component-appendix.html book-cookbook.html book-in-one-page.html cache/main.pageCache mock.html
Modified: websites/production/camel/content/book-cookbook.html == --- websites/production/camel/content/book-cookbook.html (original) +++ websites/production/camel/content/book-cookbook.html Sun Jun 14 07:21:15 2015 @@ -1099,54 +1099,18 @@ return new ProcessBuilder(jpaTemplate, t pSo you could query data from various Camel a shape=rect href=components.htmlComponents/a such as a shape=rect href=file2.htmlFile/a, a shape=rect href=http.htmlHTTP/a or a shape=rect href=jpa.htmlJPA/a, perform multiple patterns such as a shape=rect href=splitter.htmlSplitter/a or a shape=rect href=message-translator.htmlMessage Translator/a then send the messages to some other a shape=rect href=component.htmlComponent/a./p pTo show how this all fits together, try the a shape=rect href=etl-example.htmlETL Example/a /p -h2 id=Bookcookbook-MockComponentMock Component/h2 - -a shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a. - -pThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://jmock.org; rel=nofollowjMock/a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected. /p - -pThis allows you to test various things like:/p -ulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a or a shape=rect href=xquery.htmlXQuery/a a shape=rect href=expression.htmlExpression/a./li/ul - - -pstrongNote/strong that there is also the a shape=rect href=test.htmlTest endpoint/a which is a Mock endpoint, but which uses a second endpoint to provide the list of expected message bodies and automatically sets up the Mock endpoint assertions. In other words, it's a Mock endpoint that automatically sets up its assertions from some sample messages in a a shape=rect href=file2.htmlFile/a or a shape=rect href=jpa.htmldatabase/a, for example./p - -div class=aui-message problem shadowed information-macro +h2 id=Bookcookbook-MockComponentMock Component/h2pa shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a./ppThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://www.jmock.org; rel=nofollowjMock/aa shape=rect class=external-link href=http://jmock.org; rel=nofollow /a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected./ppThis allows you to test various things like:/pulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a or a
svn commit: r954779 [4/4] - in /websites/production/camel/content: book-component-appendix.html book-cookbook.html book-in-one-page.html cache/main.pageCache mock.html
Modified: websites/production/camel/content/mock.html == --- websites/production/camel/content/mock.html (original) +++ websites/production/camel/content/mock.html Sun Jun 14 07:21:15 2015 @@ -86,54 +86,18 @@ tbody tr td valign=top width=100% -div class=wiki-content maincontenth2 id=Mock-MockComponentMock Component/h2 - -a shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a. - -pThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://jmock.org; rel=nofollowjMock/a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected. /p - -pThis allows you to test various things like:/p -ulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a or a shape=rect href=xquery.htmlXQuery/a a shape=rect href=expression.htmlExpression/a./li/ul - - -pstrongNote/strong that there is also the a shape=rect href=test.htmlTest endpoint/a which is a Mock endpoint, but which uses a second endpoint to provide the list of expected message bodies and automatically sets up the Mock endpoint assertions. In other words, it's a Mock endpoint that automatically sets up its assertions from some sample messages in a a shape=rect href=file2.htmlFile/a or a shape=rect href=jpa.htmldatabase/a, for example./p - -div class=aui-message problem shadowed information-macro +div class=wiki-content maincontenth2 id=Mock-MockComponentMock Component/h2pa shape=rect href=testing.htmlTesting/a of distributed and asynchronous processing is notoriously difficult. The a shape=rect href=mock.htmlMock/a, a shape=rect href=test.htmlTest/a and a shape=rect href=dataset.htmlDataSet/a endpoints work great with the a shape=rect href=testing.htmlCamel Testing Framework/a to simplify your unit and integration testing using a shape=rect href=enterprise-integration-patterns.htmlEnterprise Integration Patterns/a and Camel's large range of a shape=rect href=components.htmlComponents/a together with the powerful a shape=rect href=bean-integration.htmlBean Integration/a./ppThe Mock component provides a powerful declarative testing mechanism, which is similar to a shape=rect class=external-link href=http://www.jmock.org; rel=nofollowjMock/aa shape=rect class=external-link href=http ://jmock.org rel=nofollow/a in that it allows declarative expectations to be created on any Mock endpoint before a test begins. Then the test is run, which typically fires messages to one or more endpoints, and finally the expectations can be asserted in a test case to ensure the system worked as expected./ppThis allows you to test various things like:/pulliThe correct number of messages are received on each endpoint,/liliThe correct payloads are received, in the right order,/liliMessages arrive on an endpoint in order, using some a shape=rect href=expression.htmlExpression/a to create an order testing function,/liliMessages arrive match some kind of a shape=rect href=predicate.htmlPredicate/a such as that specific headers have certain values, or that parts of the messages match some predicate, such as by evaluating an a shape=rect href=xpath.htmlXPath/a or a shape=rect href=xquery.htmlXQuery/a a shape=rect href=express ion.htmlExpression/a./li/ulpstrongNote/strong that there is also the a shape=rect href=test.htmlTest endpoint/a which is a Mock endpoint, but which uses a second endpoint to provide the list of expected message bodies and automatically sets up the Mock endpoint assertions. In other words, it's a Mock endpoint that automatically sets up its assertions from some sample messages in a a shape=rect href=file2.htmlFile/a or a shape=rect
camel git commit: Upgrade Atmosphere Runtime to version 2.3.2
Repository: camel Updated Branches: refs/heads/master 5522312cb - 3bf0588cc Upgrade Atmosphere Runtime to version 2.3.2 Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3bf0588c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3bf0588c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3bf0588c Branch: refs/heads/master Commit: 3bf0588cc05dc84408c7032f6f858e17382a650b Parents: 5522312 Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 00:09:13 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 09:36:58 2015 +0200 -- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/3bf0588c/parent/pom.xml -- diff --git a/parent/pom.xml b/parent/pom.xml index a05a0eb..fd053b6 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -55,7 +55,7 @@ asm-version3.3.1/asm-version aspectj-version1.8.5/aspectj-version atmos-client-version2.2.2/atmos-client-version -atmosphere-version2.2.6/atmosphere-version +atmosphere-version2.3.2/atmosphere-version atmosphere-version-range[2.0,3.0)/atmosphere-version-range atomikos-transactions-version3.9.3/atomikos-transactions-version avalon-bundle-version4.3.1_1/avalon-bundle-version
camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 8739eafec - 3c4b97f03 Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3c4b97f0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3c4b97f0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3c4b97f0 Branch: refs/heads/master Commit: 3c4b97f03bc907a8045c945d316c4fbb7dfbbd8f Parents: 8739eaf Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 17:44:17 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 17:44:17 2015 +0200 -- .../camel/component/cometd/CometdComponent.java | 18 ++ .../camel/component/cometd/CometdConsumer.java | 2 +- .../camel/component/cometd/CometdEndpoint.java | 62 .../component/cometd/CometdConsumerTest.java| 2 +- .../cometd/CometdProducerConsumerTest.java | 2 +- 5 files changed, 70 insertions(+), 16 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/3c4b97f0/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java -- diff --git a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java index fed38ae..50e3b53 100644 --- a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java +++ b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java @@ -256,18 +256,30 @@ public class CometdComponent extends UriEndpointComponent { return sslKeystore; } +/** + * The password for the keystore when using SSL. + */ public void setSslKeyPassword(String sslKeyPassword) { this.sslKeyPassword = sslKeyPassword; } +/** + * The password when using SSL. + */ public void setSslPassword(String sslPassword) { this.sslPassword = sslPassword; } +/** + * The path to the keystore. + */ public void setSslKeystore(String sslKeystore) { this.sslKeystore = sslKeystore; } +/** + * To use a custom configured SecurityPolicy to control authorization + */ public void setSecurityPolicy(SecurityPolicy securityPolicy) { this.securityPolicy = securityPolicy; } @@ -280,6 +292,9 @@ public class CometdComponent extends UriEndpointComponent { return extensions; } +/** + * To use a list of custom BayeuxServer.Extension that allows modifying incoming and outgoing requests. + */ public void setExtensions(ListBayeuxServer.Extension extensions) { this.extensions = extensions; } @@ -302,6 +317,9 @@ public class CometdComponent extends UriEndpointComponent { return sslContextParameters; } +/** + * To configure security using SSLContextParameters + */ public void setSslContextParameters(SSLContextParameters sslContextParameters) { this.sslContextParameters = sslContextParameters; } http://git-wip-us.apache.org/repos/asf/camel/blob/3c4b97f0/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java -- diff --git a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java index 8b8470e..3ddf9f6 100644 --- a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java +++ b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java @@ -85,7 +85,7 @@ public class CometdConsumer extends DefaultConsumer implements CometdProducerCon } private CometdBinding createBinding(BayeuxServerImpl bayeux) { -boolean enableSessionHeaders = endpoint == null ? false : endpoint.areSessionHeadersEnabled(); +boolean enableSessionHeaders = endpoint == null ? false : endpoint.isSessionHeadersEnabled(); return new CometdBinding(bayeux, enableSessionHeaders); } http://git-wip-us.apache.org/repos/asf/camel/blob/3c4b97f0/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java -- diff --git a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdEndpoint.java index d553ff0..43d2a35 100644 ---
camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 1e9700b05 - 8739eafec Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8739eafe Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8739eafe Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8739eafe Branch: refs/heads/master Commit: 8739eafec2d21a129e33c3e7d8a9040e2118c5d4 Parents: 1e9700b Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 17:03:18 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 17:03:18 2015 +0200 -- .../netty4/http/NettyHttpComponent.java | 9 +++ .../netty4/http/NettyHttpConfiguration.java | 68 .../netty4/http/NettyHttpEndpoint.java | 22 +++ 3 files changed, 87 insertions(+), 12 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/8739eafe/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpComponent.java -- diff --git a/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpComponent.java b/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpComponent.java index 901ff14..bb77cbf 100644 --- a/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpComponent.java +++ b/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpComponent.java @@ -171,6 +171,9 @@ public class NettyHttpComponent extends NettyComponent implements HeaderFilterSt return nettyHttpBinding; } +/** + * To use a custom org.apache.camel.component.netty4.http.NettyHttpBinding for binding to/from Netty and Camel Message API. + */ public void setNettyHttpBinding(NettyHttpBinding nettyHttpBinding) { this.nettyHttpBinding = nettyHttpBinding; } @@ -179,6 +182,9 @@ public class NettyHttpComponent extends NettyComponent implements HeaderFilterSt return headerFilterStrategy; } +/** + * To use a custom org.apache.camel.spi.HeaderFilterStrategy to filter headers. + */ public void setHeaderFilterStrategy(HeaderFilterStrategy headerFilterStrategy) { this.headerFilterStrategy = headerFilterStrategy; } @@ -187,6 +193,9 @@ public class NettyHttpComponent extends NettyComponent implements HeaderFilterSt return securityConfiguration; } +/** + * Refers to a org.apache.camel.component.netty4.http.NettyHttpSecurityConfiguration for configuring secure web resources. + */ public void setSecurityConfiguration(NettyHttpSecurityConfiguration securityConfiguration) { this.securityConfiguration = securityConfiguration; } http://git-wip-us.apache.org/repos/asf/camel/blob/8739eafe/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpConfiguration.java -- diff --git a/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpConfiguration.java b/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpConfiguration.java index 50a4ffb..468d6f8 100644 --- a/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpConfiguration.java +++ b/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyHttpConfiguration.java @@ -22,6 +22,7 @@ import java.util.List; import io.netty.channel.ChannelHandler; import org.apache.camel.RuntimeCamelException; import org.apache.camel.component.netty4.NettyConfiguration; +import org.apache.camel.spi.Metadata; import org.apache.camel.spi.UriParam; import org.apache.camel.spi.UriParams; import org.apache.camel.spi.UriPath; @@ -32,7 +33,7 @@ import org.apache.camel.spi.UriPath; @UriParams public class NettyHttpConfiguration extends NettyConfiguration { -@UriPath +@UriPath @Metadata(required = true) private String path; @UriParam private boolean urlDecodeHeaders; @@ -50,12 +51,10 @@ public class NettyHttpConfiguration extends NettyConfiguration { private boolean bridgeEndpoint; @UriParam private boolean disableStreamCache; -@UriParam(defaultValue = true) +@UriParam(label = consumer, defaultValue = true) private boolean send503whenSuspended = true; @UriParam(defaultValue = + 1024 * 1024) private int chunkedMaxContentLength = 1024 * 1024; -@UriParam(defaultValue = true) -private boolean chunked = true; public NettyHttpConfiguration() { // we need sync=true as http is request/reply by nature @@ -85,6
[3/4] camel git commit: CAMEL-8869 Resolve Switching httpClient from 4.3.x to 4.4.x break tests
CAMEL-8869 Resolve Switching httpClient from 4.3.x to 4.4.x break tests Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/82526729 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/82526729 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/82526729 Branch: refs/heads/master Commit: 825267293d5a5a32c41cd95cd540abee76cc514d Parents: 2da8f19 Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 23:05:33 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 23:52:58 2015 +0200 -- .../component/http4/HttpAuthenticationTest.java | 36 ++--- .../camel/component/http4/HttpBodyTest.java | 52 +-- .../component/http4/HttpBridgeEndpointTest.java | 41 -- .../component/http4/HttpCamelHeadersTest.java | 47 +-- .../camel/component/http4/HttpCharsetTest.java | 43 -- .../component/http4/HttpCompressionTest.java| 47 +-- .../component/http4/HttpConcurrentTest.java | 54 ++-- .../http4/HttpDefaultPortNumberTest.java| 51 +-- .../camel/component/http4/HttpMethodsTest.java | 70 +++--- .../http4/HttpNoConnectionRedeliveryTest.java | 42 -- .../component/http4/HttpNoConnectionTest.java | 44 -- .../camel/component/http4/HttpPathTest.java | 46 +-- .../http4/HttpPollingConsumerTest.java | 43 -- .../http4/HttpProducerContentTypeTest.java | 60 +--- .../http4/HttpProducerSelectMethodTest.java | 54 ++-- .../HttpProducerTwoHeadersWithSameKeyTest.java | 83 --- ...ttpProducerTwoParametersWithSameKeyTest.java | 63 ++--- .../component/http4/HttpProxyServerTest.java| 137 ++- .../camel/component/http4/HttpQueryTest.java| 50 +-- .../camel/component/http4/HttpRedirectTest.java | 47 +-- .../component/http4/HttpSOTimeoutTest.java | 41 -- .../http4/HttpThrowExceptionOnFailureTest.java | 41 -- .../http4/HttpWithHttpUriHeaderTest.java| 34 - .../http4/HttpsAuthenticationTest.java | 41 +- .../camel/component/http4/HttpsGetTest.java | 34 - .../http4/HttpsSslContextParametersGetTest.java | 41 +- ...woComponentsSslContextParametersGetTest.java | 34 - ...TwoDifferentSslContextParametersGetTest.java | 34 - 28 files changed, 1033 insertions(+), 377 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/82526729/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java -- diff --git a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java index 3a29ef7..4d6e947 100644 --- a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java +++ b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java @@ -44,21 +44,21 @@ import org.junit.Test; */ public class HttpAuthenticationTest extends BaseHttpTest { +private HttpServer localServer; + private String user = camel; private String password = password; - -protected HttpServer localServer; - + @Before @Override public void setUp() throws Exception { localServer = ServerBootstrap.bootstrap(). - setHttpProcessor(getBasicHttpProcessor()). - setConnectionReuseStrategy(getConnectionReuseStrategy()). - setResponseFactory(getHttpResponseFactory()). - setExpectationVerifier(getHttpExpectationVerifier()). - setSslContext(getSSLContext()). - registerHandler(/search, new AuthenticationValidationHandler(GET, null, null, getExpectedContent(), user, password)).create(); +setHttpProcessor(getBasicHttpProcessor()). +setConnectionReuseStrategy(getConnectionReuseStrategy()). +setResponseFactory(getHttpResponseFactory()). +setExpectationVerifier(getHttpExpectationVerifier()). +setSslContext(getSSLContext()). +registerHandler(/search, new AuthenticationValidationHandler(GET, null, null, getExpectedContent(), user, password)).create(); localServer.start(); super.setUp(); @@ -76,10 +76,11 @@ public class HttpAuthenticationTest extends BaseHttpTest { @Test public void basicAuthenticationShouldSuccess() throws Exception { -Exchange exchange = template.request(http4:// + localServer.getInetAddress().getHostName() + : + localServer.getLocalPort() +
[2/4] camel git commit: CAMEL-8869 Resolve Switching httpClient from 4.3.x to 4.4.x break tests
http://git-wip-us.apache.org/repos/asf/camel/blob/82526729/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpProxyServerTest.java -- diff --git a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpProxyServerTest.java b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpProxyServerTest.java index 7fc0d2d..edd23e8 100644 --- a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpProxyServerTest.java +++ b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpProxyServerTest.java @@ -24,6 +24,7 @@ import java.util.Map; import org.apache.camel.Exchange; import org.apache.camel.Processor; +import org.apache.camel.component.http4.handler.BasicValidationHandler; import org.apache.camel.component.http4.handler.HeaderValidationHandler; import org.apache.camel.component.http4.handler.ProxyAuthenticationValidationHandler; import org.apache.camel.util.URISupport; @@ -39,8 +40,12 @@ import org.apache.http.HttpResponseInterceptor; import org.apache.http.HttpStatus; import org.apache.http.ProtocolException; import org.apache.http.auth.AUTH; -import org.apache.http.localserver.LocalTestServer; +import org.apache.http.impl.bootstrap.HttpServer; +import org.apache.http.impl.bootstrap.ServerBootstrap; +import org.apache.http.localserver.RequestBasicAuth; +import org.apache.http.localserver.ResponseBasicUnauthorized; import org.apache.http.protocol.HttpContext; +import org.apache.http.protocol.HttpProcessor; import org.apache.http.protocol.ImmutableHttpProcessor; import org.apache.http.protocol.ResponseContent; import org.junit.After; @@ -52,37 +57,48 @@ import org.junit.Test; * @version */ public class HttpProxyServerTest extends BaseHttpTest { - -private LocalTestServer proxy; -private String user = camel; -private String password = password; - -@Override + +private HttpServer proxy; + @Before +@Override public void setUp() throws Exception { -super.setUp(); - -ListHttpRequestInterceptor requestInterceptors = new ArrayListHttpRequestInterceptor(); -requestInterceptors.add(new RequestProxyBasicAuth()); -ListHttpResponseInterceptor responseInterceptors = new ArrayListHttpResponseInterceptor(); -responseInterceptors.add(new ResponseContent()); -responseInterceptors.add(new ResponseProxyBasicUnauthorized()); -ImmutableHttpProcessor httpproc = new ImmutableHttpProcessor(requestInterceptors, responseInterceptors); - -proxy = new LocalTestServer(httpproc, null); +MapString, String expectedHeaders = new HashMapString, String(); +expectedHeaders.put(Proxy-Connection, Keep-Alive); +proxy = ServerBootstrap.bootstrap(). +setHttpProcessor(getBasicHttpProcessor()). +setConnectionReuseStrategy(getConnectionReuseStrategy()). +setResponseFactory(getHttpResponseFactory()). +setExpectationVerifier(getHttpExpectationVerifier()). +setSslContext(getSSLContext()). +registerHandler(*, new HeaderValidationHandler(GET, null, null, getExpectedContent(), expectedHeaders)).create(); proxy.start(); + +super.setUp(); } -@Override @After +@Override public void tearDown() throws Exception { +super.tearDown(); + if (proxy != null) { proxy.stop(); } - -super.tearDown(); } +@Override +protected HttpProcessor getBasicHttpProcessor() { +ListHttpRequestInterceptor requestInterceptors = new ArrayListHttpRequestInterceptor(); +requestInterceptors.add(new RequestProxyBasicAuth()); +ListHttpResponseInterceptor responseInterceptors = new ArrayListHttpResponseInterceptor(); +responseInterceptors.add(new ResponseContent()); +responseInterceptors.add(new ResponseProxyBasicUnauthorized()); +ImmutableHttpProcessor httpproc = new ImmutableHttpProcessor(requestInterceptors, responseInterceptors); +return httpproc; +} + + @Test public void testDifferentHttpProxyConfigured() throws Exception { HttpEndpoint http1 = context.getEndpoint(http4://www.google.com?proxyAuthHost=myproxyproxyAuthPort=1234, HttpEndpoint.class); @@ -99,12 +115,8 @@ public class HttpProxyServerTest extends BaseHttpTest { @Test public void httpGetWithProxyAndWithoutUser() throws Exception { -MapString, String expectedHeaders = new HashMapString, String(); -expectedHeaders.put(Host, getHostName() + : + getPort()); -expectedHeaders.put(Proxy-Connection, Keep-Alive); -proxy.register(*, new HeaderValidationHandler(GET, null, null, getExpectedContent(), expectedHeaders)); -Exchange exchange = template.request(http4:// +
[4/4] camel git commit: Component docs
Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bd881496 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bd881496 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bd881496 Branch: refs/heads/master Commit: bd881496e4bc80695d4a26c4334c91b51f754554 Parents: 8252672 Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 23:53:56 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 23:53:56 2015 +0200 -- .../org/apache/camel/component/http4/HttpServerTestSupport.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/bd881496/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpServerTestSupport.java -- diff --git a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpServerTestSupport.java b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpServerTestSupport.java index 7fc1cc8..4a63e86 100644 --- a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpServerTestSupport.java +++ b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpServerTestSupport.java @@ -26,8 +26,7 @@ import org.apache.http.protocol.HttpProcessor; /** * Abstract base class for unit testing using a http server. - * The setUp method starts the server before the camel context is started and - * the tearDown method stops the server after the camel context is stopped. + * This class contains an empty configuration to be used. * * @version */
[1/4] camel git commit: CAMEL-8869 Upgrade httpcore and httpclient to version 4.4.1 and start refactoring tests
Repository: camel Updated Branches: refs/heads/master 3c4b97f03 - bd881496e CAMEL-8869 Upgrade httpcore and httpclient to version 4.4.1 and start refactoring tests Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2da8f198 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2da8f198 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2da8f198 Branch: refs/heads/master Commit: 2da8f198b0f4ad303f2a4984403581b26a489ffc Parents: 3c4b97f Author: Andrea Cosentino anco...@gmail.com Authored: Sun Jun 14 15:33:00 2015 +0200 Committer: Andrea Cosentino anco...@gmail.com Committed: Sun Jun 14 23:51:24 2015 +0200 -- .../camel/component/http4/BaseHttpTest.java | 1 + .../component/http4/HttpAuthenticationTest.java | 45 +++ .../component/http4/HttpServerTestSupport.java | 59 parent/pom.xml | 4 +- 4 files changed, 38 insertions(+), 71 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/2da8f198/components/camel-http4/src/test/java/org/apache/camel/component/http4/BaseHttpTest.java -- diff --git a/components/camel-http4/src/test/java/org/apache/camel/component/http4/BaseHttpTest.java b/components/camel-http4/src/test/java/org/apache/camel/component/http4/BaseHttpTest.java index 1fd8d1c..ab9840a 100644 --- a/components/camel-http4/src/test/java/org/apache/camel/component/http4/BaseHttpTest.java +++ b/components/camel-http4/src/test/java/org/apache/camel/component/http4/BaseHttpTest.java @@ -20,6 +20,7 @@ import java.util.Map; import org.apache.camel.Exchange; import org.apache.camel.Message; +import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.http.HttpStatus; /** http://git-wip-us.apache.org/repos/asf/camel/blob/2da8f198/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java -- diff --git a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java index 5ca499c..3a29ef7 100644 --- a/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java +++ b/components/camel-http4/src/test/java/org/apache/camel/component/http4/HttpAuthenticationTest.java @@ -27,12 +27,15 @@ import org.apache.camel.component.http4.handler.AuthenticationValidationHandler; import org.apache.http.HttpRequestInterceptor; import org.apache.http.HttpResponseInterceptor; import org.apache.http.HttpStatus; -import org.apache.http.localserver.LocalTestServer; +import org.apache.http.impl.bootstrap.HttpServer; +import org.apache.http.impl.bootstrap.ServerBootstrap; import org.apache.http.localserver.RequestBasicAuth; import org.apache.http.localserver.ResponseBasicUnauthorized; import org.apache.http.protocol.HttpProcessor; import org.apache.http.protocol.ImmutableHttpProcessor; import org.apache.http.protocol.ResponseContent; +import org.junit.After; +import org.junit.Before; import org.junit.Test; /** @@ -43,10 +46,37 @@ public class HttpAuthenticationTest extends BaseHttpTest { private String user = camel; private String password = password; + +protected HttpServer localServer; + +@Before +@Override +public void setUp() throws Exception { +localServer = ServerBootstrap.bootstrap(). + setHttpProcessor(getBasicHttpProcessor()). + setConnectionReuseStrategy(getConnectionReuseStrategy()). + setResponseFactory(getHttpResponseFactory()). + setExpectationVerifier(getHttpExpectationVerifier()). + setSslContext(getSSLContext()). + registerHandler(/search, new AuthenticationValidationHandler(GET, null, null, getExpectedContent(), user, password)).create(); +localServer.start(); + +super.setUp(); +} + +@After +@Override +public void tearDown() throws Exception { +super.tearDown(); +if (localServer != null) { +localServer.stop(); +} +} + @Test public void basicAuthenticationShouldSuccess() throws Exception { -Exchange exchange = template.request(http4:// + getHostName() + : + getPort() + /search?authUsername= + user + authPassword= + password, new Processor() { +Exchange exchange = template.request(http4:// + localServer.getInetAddress().getHostName() + : + localServer.getLocalPort() + /search?authUsername= + user + authPassword= + password, new Processor() { public
camel git commit: Component docs
Repository: camel Updated Branches: refs/heads/master 63df40219 - 1e9700b05 Component docs Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1e9700b0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1e9700b0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1e9700b0 Branch: refs/heads/master Commit: 1e9700b05bcfd5f1bc7cc5ad9e8c76ea03d18ff2 Parents: 63df402 Author: Claus Ibsen davscl...@apache.org Authored: Sun Jun 14 16:40:24 2015 +0200 Committer: Claus Ibsen davscl...@apache.org Committed: Sun Jun 14 16:55:41 2015 +0200 -- .../component/jetty/JettyHttpComponent.java | 8 +- .../component/jetty/JettyHttpEndpoint.java | 103 +++ .../netty/http/NettyHttpComponent.java | 9 ++ .../netty/http/NettyHttpConfiguration.java | 68 +--- .../component/netty/http/NettyHttpEndpoint.java | 22 5 files changed, 172 insertions(+), 38 deletions(-) -- http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java -- diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java index c3bc309..d079be2 100644 --- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java +++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java @@ -29,7 +29,6 @@ import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; - import javax.management.MBeanServer; import javax.servlet.Filter; import javax.servlet.RequestDispatcher; @@ -362,7 +361,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo connectorRef.servlet.connect(consumer); } } - private void enableJmx(Server server) { MBeanContainer containerToRegister = getMbContainer(); @@ -500,7 +498,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo return sslKeystore; } - public ErrorHandler getErrorHandler() { return errorHandler; } @@ -542,7 +539,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo protected Connector createConnector(Server server, JettyHttpEndpoint endpoint) { - // now we just use the SelectChannelConnector as the default connector SslContextFactory sslcf = null; @@ -627,7 +623,7 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo * Creates a new {@link HttpClient} and configures its proxy/thread pool and SSL based on this * component settings. * - * @Param endpoint the instance of JettyHttpEndpoint + * @param endpoint the instance of JettyHttpEndpoint * @param minThreads optional minimum number of threads in client thread pool * @param maxThreads optional maximum number of threads in client thread pool * @param ssloption SSL parameters @@ -873,7 +869,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo // Implementation methods // - - @Override public Consumer createConsumer(CamelContext camelContext, Processor processor, String verb, String basePath, String uriTemplate, String consumes, String produces, MapString, Object parameters) throws Exception { @@ -1014,7 +1009,6 @@ public abstract class JettyHttpComponent extends HttpComponent implements RestCo } } } - } protected Server createServer() { http://git-wip-us.apache.org/repos/asf/camel/blob/1e9700b0/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java -- diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java index 4b17416..12d944c 100644 --- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java +++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java @@ -42,31 +42,49 @@ import org.eclipse.jetty.server.Handler; */ public abstract class JettyHttpEndpoint