[jira] [Commented] (CAMEL-12888) The camel-maven-package-plugin issue wrong short java type
[ https://issues.apache.org/jira/browse/CAMEL-12888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654067#comment-16654067 ] Alex Dettinger commented on CAMEL-12888: I've corrected the ComponentOptionModel part. I will report the same kind of fix for other parts of the model. > The camel-maven-package-plugin issue wrong short java type > -- > > Key: CAMEL-12888 > URL: https://issues.apache.org/jira/browse/CAMEL-12888 > Project: Camel > Issue Type: Bug > Components: tooling >Affects Versions: 2.23.0 >Reporter: Alex Dettinger >Assignee: Alex Dettinger >Priority: Minor > > For instance, [the seda component documentation > |https://github.com/apache/camel/blob/master/camel-core/src/main/docs/seda-component.adoc] > exhibits *Exchange>* as the type for the option *defaultQueueFactory* > whereas we should issue *BlockingQueueFactory*. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12888) The camel-maven-package-plugin issue wrong short java type
[ https://issues.apache.org/jira/browse/CAMEL-12888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654058#comment-16654058 ] ASF GitHub Bot commented on CAMEL-12888: aldettinger closed pull request #2567: CAMEL-12888: Fixed the short java type generation in camel-package-ma… URL: https://github.com/apache/camel/pull/2567 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/camel-core/src/main/docs/seda-component.adoc b/camel-core/src/main/docs/seda-component.adoc index d12159c8f1d..cdc99f3ef8d 100644 --- a/camel-core/src/main/docs/seda-component.adoc +++ b/camel-core/src/main/docs/seda-component.adoc @@ -48,7 +48,7 @@ The SEDA component supports 6 options, which are listed below. | Name | Description | Default | Type | *queueSize* (advanced) | Sets the default maximum capacity of the SEDA queue (i.e., the number of messages it can hold). | 1000 | int | *concurrentConsumers* (consumer) | Sets the default number of concurrent threads processing exchanges. | 1 | int -| *defaultQueueFactory* (advanced) | Sets the default queue factory. | | Exchange> +| *defaultQueueFactory* (advanced) | Sets the default queue factory. | | BlockingQueueFactory | *defaultBlockWhenFull* (producer) | Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted. By default, an exception will be thrown stating that the queue is full. By enabling this option, the calling thread will instead block and wait until the message can be accepted. | false | boolean | *defaultOfferTimeout* (producer) | Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted. By default, an exception will be thrown stating that the queue is full. By enabling this option, where a configured timeout can be added to the block case. Utilizing the .offer(timeout) method of the underlining java queue | | long | *resolveProperty Placeholders* (advanced) | Whether the component should resolve property placeholders on itself when starting. Only properties which are of String type can use property placeholders. | true | boolean diff --git a/camel-core/src/main/docs/stub-component.adoc b/camel-core/src/main/docs/stub-component.adoc index eb112d36cd9..8f7840c9ba9 100644 --- a/camel-core/src/main/docs/stub-component.adoc +++ b/camel-core/src/main/docs/stub-component.adoc @@ -38,7 +38,7 @@ The Stub component supports 6 options, which are listed below. | Name | Description | Default | Type | *queueSize* (advanced) | Sets the default maximum capacity of the SEDA queue (i.e., the number of messages it can hold). | 1000 | int | *concurrentConsumers* (consumer) | Sets the default number of concurrent threads processing exchanges. | 1 | int -| *defaultQueueFactory* (advanced) | Sets the default queue factory. | | Exchange> +| *defaultQueueFactory* (advanced) | Sets the default queue factory. | | BlockingQueueFactory | *defaultBlockWhenFull* (producer) | Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted. By default, an exception will be thrown stating that the queue is full. By enabling this option, the calling thread will instead block and wait until the message can be accepted. | false | boolean | *defaultOfferTimeout* (producer) | Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted. By default, an exception will be thrown stating that the queue is full. By enabling this option, where a configured timeout can be added to the block case. Utilizing the .offer(timeout) method of the underlining java queue | | long | *resolveProperty Placeholders* (advanced) | Whether the component should resolve property placeholders on itself when starting. Only properties which are of String type can use property placeholders. | true | boolean diff --git a/camel-core/src/main/docs/vm-component.adoc b/camel-core/src/main/docs/vm-component.adoc index 8e1c3a9128f..9b9279a8b0e 100644 --- a/camel-core/src/main/docs/vm-component.adoc +++ b/camel-core/src/main/docs/vm-component.adoc @@ -68,7 +68,7 @@ The VM component supports 6 options, which are listed below. | Name | Description | Default | Type | *queueSize* (advanced) | Sets the default maximum capacity of the SEDA queue (i.e., the number of messages it can hold). | 1000 | int | *concurrentConsumers* (consumer) | Sets the default number of concurrent threads processing exchanges. | 1 | int -| *defaultQueueFactory* (advanced) | Sets the default queue factory. | | Exchange> +| *defaultQueueFactory* (advanced) | Sets
[jira] [Commented] (CAMEL-12888) The camel-maven-package-plugin issue wrong short java type
[ https://issues.apache.org/jira/browse/CAMEL-12888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654057#comment-16654057 ] ASF GitHub Bot commented on CAMEL-12888: aldettinger commented on issue #2567: CAMEL-12888: Fixed the short java type generation in camel-package-ma… URL: https://github.com/apache/camel/pull/2567#issuecomment-430749645 Nice catch, I will add this test indeed and apply the same kind of correction on other model classes from the camel-package-maven-plugin. Thanks @onderson and @oscerd. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > The camel-maven-package-plugin issue wrong short java type > -- > > Key: CAMEL-12888 > URL: https://issues.apache.org/jira/browse/CAMEL-12888 > Project: Camel > Issue Type: Bug > Components: tooling >Affects Versions: 2.23.0 >Reporter: Alex Dettinger >Assignee: Alex Dettinger >Priority: Minor > > For instance, [the seda component documentation > |https://github.com/apache/camel/blob/master/camel-core/src/main/docs/seda-component.adoc] > exhibits *Exchange>* as the type for the option *defaultQueueFactory* > whereas we should issue *BlockingQueueFactory*. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12887) In case of disconnect relogin is not working
[ https://issues.apache.org/jira/browse/CAMEL-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653815#comment-16653815 ] bhavishya commented on CAMEL-12887: --- I would try to reproduce but since this is coming in prod so it would be hard to change engine . On Wed, Oct 17, 2018 at 9:41 PM Luca Burgazzoli (JIRA) -- Regards Bhavishya Goyal > In case of disconnect relogin is not working > > > Key: CAMEL-12887 > URL: https://issues.apache.org/jira/browse/CAMEL-12887 > Project: Camel > Issue Type: Bug > Components: camel-quickfix >Affects Versions: 2.14.1 > Environment: JAVA 8 > Ubuntu 16 >Reporter: bhavishya >Priority: Major > > My application is sending logon request and getting logon response and > session get logged in perfectly at first time . After some time session get > disconnected due to heartbeat timeout and my application send login again and > acceptor send login response within same second but my initiator don't get > connected after 10 second it send another login request. Ideally it should > not send login request again. > Event logs are > 20181015-13:36:34: Sent test request TEST > 20181015-13:37:01: Disconnecting: Timed out waiting for heartbeat > 20181015-13:37:02: Initiated logon request > 20181015-13:37:13: Disconnecting: Timed out waiting for logon response > 20181015-13:37:32: Disconnecting: Socket exception (/192.168.40.29:31815): > java.io.IOException: Connection reset by peer > 20181015-13:38:02: Initiated logon request > Message logs > 8=FIX.4.2^A9=69^A35=A^A34=1064^A49=test^A52=20181015-13:37:02.570^A56=test^A98=0^A108=30^A10=075^A > 8=FIX.4.2^A9=000593^A35=A^A34=001527^A43=N^A52=20181015-13:37:02^A49=test^A56=test^A98=0^A108=30^A6247=prod^A6272=AMEX/OPT,CBOE/OPT,PHLX/OPT,PSE/OPT,DTB/OPT,ISE/OPT,BELFOX/OPT,GLOBEX/FOP,MONEP/OPT,SOFFEX/OPT,FTA/OPT,ASX/OPT,BOX/OPT,ECBOT/FOP,IBCX/BAG,BATS/OPT,NASDAQOM/OPT,ICEEU/OPT^A6382=S3^A6387=s3.amazonaws.com^A6386=0WWXP5X5ZAMQC93NZR82^A6492=1^A6541=1^A6530=1^A6550=1^A6560=1/Maximize > Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize Fill,2/Primary > Exchange,3/Highest Volume Exchange With Rebate,4/High Volume Exchange With > Lowest Fee^A6749=1/Maximize Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize > Fill^A8035=5bc41694.^A10=210^A > 8=FIX.4.2^A9=69^A35=A^A34=1065^A49=test^A52=20181015-13:38:02.569^A56=test^A98=0^A108=30^A10=085^A > 8=FIX.4.2^A9=000593^A35=A^A34=001528^A43=N^A52=20181015-13:38:02^A49=test^A56=test^A98=0^A108=30^A6247=prod^A6272=AMEX/OPT,CBOE/OPT,PHLX/OPT,PSE/OPT,DTB/OPT,ISE/OPT,BELFOX/OPT,GLOBEX/FOP,MONEP/OPT,SOFFEX/OPT,FTA/OPT,ASX/OPT,BOX/OPT,ECBOT/FOP,IBCX/BAG,BATS/OPT,NASDAQOM/OPT,ICEEU/OPT^A6382=S3^A6387=s3.amazonaws.com^A6386=0WWXP5X5ZAMQC93NZR82^A6492=1^A6541=1^A6530=1^A6550=1^A6560=1/Maximize > Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize Fill,2/Primary > Exchange,3/Highest Volume Exchange With Rebate,4/High Volume Exchange With > Lowest Fee^A6749=1/Maximize Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize > Fill^A8035=5bc41694.^A10=212^A > As you can see we send login request at 20181015-13:37:02.570 and get > response at 20181015-13:37:02 then still it send one more login request. > Any help would be really appreciated > > I have removed actual SendercompId and Target comp Id > > I am using camel 2.14.1 -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12887) In case of disconnect relogin is not working
[ https://issues.apache.org/jira/browse/CAMEL-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653777#comment-16653777 ] Luca Burgazzoli commented on CAMEL-12887: - the fix cinematic is not governed by camel afaik but by the underlying engine, can you check if the same behavior is observed by using a plain quickfixj app ? A reproducer would also be very welcome > In case of disconnect relogin is not working > > > Key: CAMEL-12887 > URL: https://issues.apache.org/jira/browse/CAMEL-12887 > Project: Camel > Issue Type: Bug > Components: camel-quickfix >Affects Versions: 2.14.1 > Environment: JAVA 8 > Ubuntu 16 >Reporter: bhavishya >Priority: Major > > My application is sending logon request and getting logon response and > session get logged in perfectly at first time . After some time session get > disconnected due to heartbeat timeout and my application send login again and > acceptor send login response within same second but my initiator don't get > connected after 10 second it send another login request. Ideally it should > not send login request again. > Event logs are > 20181015-13:36:34: Sent test request TEST > 20181015-13:37:01: Disconnecting: Timed out waiting for heartbeat > 20181015-13:37:02: Initiated logon request > 20181015-13:37:13: Disconnecting: Timed out waiting for logon response > 20181015-13:37:32: Disconnecting: Socket exception (/192.168.40.29:31815): > java.io.IOException: Connection reset by peer > 20181015-13:38:02: Initiated logon request > Message logs > 8=FIX.4.2^A9=69^A35=A^A34=1064^A49=test^A52=20181015-13:37:02.570^A56=test^A98=0^A108=30^A10=075^A > 8=FIX.4.2^A9=000593^A35=A^A34=001527^A43=N^A52=20181015-13:37:02^A49=test^A56=test^A98=0^A108=30^A6247=prod^A6272=AMEX/OPT,CBOE/OPT,PHLX/OPT,PSE/OPT,DTB/OPT,ISE/OPT,BELFOX/OPT,GLOBEX/FOP,MONEP/OPT,SOFFEX/OPT,FTA/OPT,ASX/OPT,BOX/OPT,ECBOT/FOP,IBCX/BAG,BATS/OPT,NASDAQOM/OPT,ICEEU/OPT^A6382=S3^A6387=s3.amazonaws.com^A6386=0WWXP5X5ZAMQC93NZR82^A6492=1^A6541=1^A6530=1^A6550=1^A6560=1/Maximize > Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize Fill,2/Primary > Exchange,3/Highest Volume Exchange With Rebate,4/High Volume Exchange With > Lowest Fee^A6749=1/Maximize Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize > Fill^A8035=5bc41694.^A10=210^A > 8=FIX.4.2^A9=69^A35=A^A34=1065^A49=test^A52=20181015-13:38:02.569^A56=test^A98=0^A108=30^A10=085^A > 8=FIX.4.2^A9=000593^A35=A^A34=001528^A43=N^A52=20181015-13:38:02^A49=test^A56=test^A98=0^A108=30^A6247=prod^A6272=AMEX/OPT,CBOE/OPT,PHLX/OPT,PSE/OPT,DTB/OPT,ISE/OPT,BELFOX/OPT,GLOBEX/FOP,MONEP/OPT,SOFFEX/OPT,FTA/OPT,ASX/OPT,BOX/OPT,ECBOT/FOP,IBCX/BAG,BATS/OPT,NASDAQOM/OPT,ICEEU/OPT^A6382=S3^A6387=s3.amazonaws.com^A6386=0WWXP5X5ZAMQC93NZR82^A6492=1^A6541=1^A6530=1^A6550=1^A6560=1/Maximize > Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize Fill,2/Primary > Exchange,3/Highest Volume Exchange With Rebate,4/High Volume Exchange With > Lowest Fee^A6749=1/Maximize Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize > Fill^A8035=5bc41694.^A10=212^A > As you can see we send login request at 20181015-13:37:02.570 and get > response at 20181015-13:37:02 then still it send one more login request. > Any help would be really appreciated > > I have removed actual SendercompId and Target comp Id > > I am using camel 2.14.1 -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12887) In case of disconnect relogin is not working
[ https://issues.apache.org/jira/browse/CAMEL-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653722#comment-16653722 ] bhavishya commented on CAMEL-12887: --- I have upgraded on 2.21 as well and facing same issue. Please can you help me on that ? On Tue, Oct 16, 2018 at 10:19 PM Andrea Cosentino (JIRA) -- Regards Bhavishya Goyal > In case of disconnect relogin is not working > > > Key: CAMEL-12887 > URL: https://issues.apache.org/jira/browse/CAMEL-12887 > Project: Camel > Issue Type: Bug > Components: camel-quickfix >Affects Versions: 2.14.1 > Environment: JAVA 8 > Ubuntu 16 >Reporter: bhavishya >Priority: Major > > My application is sending logon request and getting logon response and > session get logged in perfectly at first time . After some time session get > disconnected due to heartbeat timeout and my application send login again and > acceptor send login response within same second but my initiator don't get > connected after 10 second it send another login request. Ideally it should > not send login request again. > Event logs are > 20181015-13:36:34: Sent test request TEST > 20181015-13:37:01: Disconnecting: Timed out waiting for heartbeat > 20181015-13:37:02: Initiated logon request > 20181015-13:37:13: Disconnecting: Timed out waiting for logon response > 20181015-13:37:32: Disconnecting: Socket exception (/192.168.40.29:31815): > java.io.IOException: Connection reset by peer > 20181015-13:38:02: Initiated logon request > Message logs > 8=FIX.4.2^A9=69^A35=A^A34=1064^A49=test^A52=20181015-13:37:02.570^A56=test^A98=0^A108=30^A10=075^A > 8=FIX.4.2^A9=000593^A35=A^A34=001527^A43=N^A52=20181015-13:37:02^A49=test^A56=test^A98=0^A108=30^A6247=prod^A6272=AMEX/OPT,CBOE/OPT,PHLX/OPT,PSE/OPT,DTB/OPT,ISE/OPT,BELFOX/OPT,GLOBEX/FOP,MONEP/OPT,SOFFEX/OPT,FTA/OPT,ASX/OPT,BOX/OPT,ECBOT/FOP,IBCX/BAG,BATS/OPT,NASDAQOM/OPT,ICEEU/OPT^A6382=S3^A6387=s3.amazonaws.com^A6386=0WWXP5X5ZAMQC93NZR82^A6492=1^A6541=1^A6530=1^A6550=1^A6560=1/Maximize > Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize Fill,2/Primary > Exchange,3/Highest Volume Exchange With Rebate,4/High Volume Exchange With > Lowest Fee^A6749=1/Maximize Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize > Fill^A8035=5bc41694.^A10=210^A > 8=FIX.4.2^A9=69^A35=A^A34=1065^A49=test^A52=20181015-13:38:02.569^A56=test^A98=0^A108=30^A10=085^A > 8=FIX.4.2^A9=000593^A35=A^A34=001528^A43=N^A52=20181015-13:38:02^A49=test^A56=test^A98=0^A108=30^A6247=prod^A6272=AMEX/OPT,CBOE/OPT,PHLX/OPT,PSE/OPT,DTB/OPT,ISE/OPT,BELFOX/OPT,GLOBEX/FOP,MONEP/OPT,SOFFEX/OPT,FTA/OPT,ASX/OPT,BOX/OPT,ECBOT/FOP,IBCX/BAG,BATS/OPT,NASDAQOM/OPT,ICEEU/OPT^A6382=S3^A6387=s3.amazonaws.com^A6386=0WWXP5X5ZAMQC93NZR82^A6492=1^A6541=1^A6530=1^A6550=1^A6560=1/Maximize > Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize Fill,2/Primary > Exchange,3/Highest Volume Exchange With Rebate,4/High Volume Exchange With > Lowest Fee^A6749=1/Maximize Rebate,9/Prefer Rebate,11/Prefer Fill,12/Maximize > Fill^A8035=5bc41694.^A10=212^A > As you can see we send login request at 20181015-13:37:02.570 and get > response at 20181015-13:37:02 then still it send one more login request. > Any help would be really appreciated > > I have removed actual SendercompId and Target comp Id > > I am using camel 2.14.1 -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Issue Comment Deleted] (CAMEL-12889) useFixedDelay property of ScheduledPollConsumer has no effect
[ https://issues.apache.org/jira/browse/CAMEL-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikael Carlstedt updated CAMEL-12889: - Comment: was deleted (was: 2018-10-17 13:44:04,063 ERROR [Camel (main) thread #23 - nobill://nobillSmppConnections] c.m.a.a.s.drException [CamelLogger.java:156] Exchange[ExchangePattern: InOnly, BodyType: com.cloudhopper.smpp.pdu.DeliverSm, CaughtExceptionType: java.util.ConcurrentModificationException, CaughtExceptionMessage: null, StackTrace: java.util.ConcurrentModificationException at java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1630) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.reduce(ReferencePipeline.java:479) at java.util.stream.ReferencePipeline.max(ReferencePipeline.java:515) at com.mblox.api.adapter.sms.translation.BatchAggregationStrategy.matches(BatchAggregationStrategy.java:70) at org.apache.camel.processor.aggregate.AggregateProcessor.isCompleted(AggregateProcessor.java:606) at org.apache.camel.processor.aggregate.AggregateProcessor.doAggregation(AggregateProcessor.java:485) at org.apache.camel.processor.aggregate.AggregateProcessor.doProcess(AggregateProcessor.java:350) at org.apache.camel.processor.aggregate.AggregateProcessor.process(AggregateProcessor.java:271) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.component.direct.DirectBlockingProducer.process(DirectBlockingProducer.java:53) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:117) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.component.direct.DirectBlockingProducer.process(DirectBlockingProducer.java:53) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:117) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.component.direct.DirectBlockingProducer.process(DirectBlockingProducer.java:53) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:117) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInter
[jira] [Commented] (CAMEL-12889) useFixedDelay property of ScheduledPollConsumer has no effect
[ https://issues.apache.org/jira/browse/CAMEL-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653672#comment-16653672 ] Mikael Carlstedt commented on CAMEL-12889: -- 2018-10-17 13:44:04,063 ERROR [Camel (main) thread #23 - nobill://nobillSmppConnections] c.m.a.a.s.drException [CamelLogger.java:156] Exchange[ExchangePattern: InOnly, BodyType: com.cloudhopper.smpp.pdu.DeliverSm, CaughtExceptionType: java.util.ConcurrentModificationException, CaughtExceptionMessage: null, StackTrace: java.util.ConcurrentModificationException at java.util.HashMap$ValueSpliterator.forEachRemaining(HashMap.java:1630) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.reduce(ReferencePipeline.java:479) at java.util.stream.ReferencePipeline.max(ReferencePipeline.java:515) at com.mblox.api.adapter.sms.translation.BatchAggregationStrategy.matches(BatchAggregationStrategy.java:70) at org.apache.camel.processor.aggregate.AggregateProcessor.isCompleted(AggregateProcessor.java:606) at org.apache.camel.processor.aggregate.AggregateProcessor.doAggregation(AggregateProcessor.java:485) at org.apache.camel.processor.aggregate.AggregateProcessor.doProcess(AggregateProcessor.java:350) at org.apache.camel.processor.aggregate.AggregateProcessor.process(AggregateProcessor.java:271) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.component.direct.DirectBlockingProducer.process(DirectBlockingProducer.java:53) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:117) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.component.direct.DirectBlockingProducer.process(DirectBlockingProducer.java:53) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:117) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) at org.apache.camel.builder.NoErrorHandlerBuilder$1.process(NoErrorHandlerBuilder.java:40) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.component.direct.DirectBlockingProducer.process(DirectBlockingProducer.java:53) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:117) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) at org.apache.camel.processor.CamelInternalPr
[jira] [Created] (CAMEL-12889) useFixedDelay property of ScheduledPollConsumer has no effect
Mikael Carlstedt created CAMEL-12889: Summary: useFixedDelay property of ScheduledPollConsumer has no effect Key: CAMEL-12889 URL: https://issues.apache.org/jira/browse/CAMEL-12889 Project: Camel Issue Type: Bug Components: camel-core Reporter: Mikael Carlstedt The setUseFixedDelay() method of contained ScheduledPollConsumerScheduler instance should be called to change the behaviour when setUseFixedDelay() is called. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Resolved] (CAMEL-12884) Camel-AWS Lambda: Add support for event source mapping
[ https://issues.apache.org/jira/browse/CAMEL-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrea Cosentino resolved CAMEL-12884. -- Resolution: Fixed > Camel-AWS Lambda: Add support for event source mapping > -- > > Key: CAMEL-12884 > URL: https://issues.apache.org/jira/browse/CAMEL-12884 > Project: Camel > Issue Type: New Feature > Components: camel-aws >Reporter: Andrea Cosentino >Assignee: Andrea Cosentino >Priority: Major > Fix For: 2.23.0 > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-11497) Migrate the rest of the Confluence content
[ https://issues.apache.org/jira/browse/CAMEL-11497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653154#comment-16653154 ] ASF GitHub Bot commented on CAMEL-11497: oscerd commented on issue #2570: CAMEL-11497: Reorganise Summary page based on offical site's side menu URL: https://github.com/apache/camel/pull/2570#issuecomment-430528271 Thanks merged on master This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Migrate the rest of the Confluence content > -- > > Key: CAMEL-11497 > URL: https://issues.apache.org/jira/browse/CAMEL-11497 > Project: Camel > Issue Type: Sub-task > Components: website >Reporter: Zoran Regvart >Assignee: Önder Sezgin >Priority: Major > Fix For: Future > > > There are still pages in the Confluence that are not migrated to Asciidoctor -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-11497) Migrate the rest of the Confluence content
[ https://issues.apache.org/jira/browse/CAMEL-11497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653155#comment-16653155 ] ASF GitHub Bot commented on CAMEL-11497: oscerd closed pull request #2570: CAMEL-11497: Reorganise Summary page based on offical site's side menu URL: https://github.com/apache/camel/pull/2570 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/docs/user-manual/en/SUMMARY.md b/docs/user-manual/en/SUMMARY.md index dc14a25670e..0d0abd284b8 100644 --- a/docs/user-manual/en/SUMMARY.md +++ b/docs/user-manual/en/SUMMARY.md @@ -1,87 +1,147 @@ # Summary +* [Overview](#overview) +* [Documentation](#documentation) +* [Community](#community) +* [Developers](#developers) + +## Overview + * [Introduction](README.md) -* [Legal Notice](notice.md) +* Download * [Getting Started](getting-started.adoc) * [Longer Getting Started Guide](book-getting-started.adoc) +* FAQ +* [Legal Notice](notice.md) -* [Architecture](architecture.adoc) -* [Async](async.adoc) -* [Asynchronous Routing Engine](asynchronous-routing-engine.adoc) -* [BacklogDebugger](backlogdebugger.adoc) -* [BAM](bam.adoc) -* [Batch Consumer](batch-consumer.adoc) -* [BrowsableEndpoint](browsable-endpoint.adoc) -* [Camel Core](camel-core.adoc) -* [CamelContext](camelcontext.adoc) -* [CEP](cep.adoc) -* [Component](component.adoc) -* [Debugger](debugger.adoc) -* [Delay Interceptor](delay-interceptor.adoc) -* [Dependency Injection](dependency-injection.adoc) -* [Dozer Type Conversion](dozer-type-conversion.adoc) -* [DSL](dsl.adoc) -* [Java DSL](java-dsl.adoc) -* [Spring DSL](spring.adoc) -* [Blueprint DSL](using-osgi-blueprint-with-camel.adoc) -* [Groovy DSL](groovy-dsl.adoc) -* [Scala DSL](scala-dsl.adoc) -* [Scala DSL Getting Started](scala-dsl-getting-started.adoc) -* [Scala DSL EIP](scala-dsl-eip.adoc) -* [Scala DSL Supported Languages](scala-dsl-supported-languages.adoc) -* [Annotation DSL](bean-integration.adoc) -* [Endpoint](endpoint.adoc) -* [Error Handler](error-handler.adoc) -* [Exchange](exchange.adoc) -* [Exchange Pattern](exchange-pattern.adoc) -* [Expression](expression.adoc) -* [Injector](injector.adoc) -* [Intercept](intercept.adoc) -* [Inversion Of Control With Smart Defaults](inversion-of-control-with-smart-defaults.adoc) -* [Lifecycle](lifecycle.adoc) -* [OnCompletion](oncompletion.adoc) -* [Predicate](predicate.adoc) -* [Registry](registry.adoc) -* [RouteBuilder](route-builder.adoc) -* [Routes](routes.adoc) - - - -* [Enterprise Integration Patterns](enterprise-integration-patterns.adoc) -* [Event Message](event-message.adoc) -* [Message](message.adoc) -* [Request Reply](request-reply.adoc) - -* Community -* FAQ -* Using Camel questions -* [How do I configure endpoints](how-do-i-configure-endpoints.adoc) - - +## Documentation + +* [User Guide](#user-guide) +* Manual +* Books +* Tutorials +* [Examples](#examples) +* Cookbook +* [Architecture](#architecture) +* [Enterprise Integration Patterns](#enterprise-integration-patterns) +* [DSL](#dsl) +* [Components](#components) +* [Data Formats](#data-formats) +* [Languages](#languages) +* Security +* Security Advisories + +### User Guide +* [Getting Started](getting-started.adoc) +* [Longer Getting Started Guide](book-getting-started.adoc) +* [Camel JAR Dependencies](camel-jar-dependencies.adoc) +* [Camel Boot](camel-boot.adoc) +* [Working with Camel and CDI](../../../components/camel-cdi/src/main/docs/cdi.adoc) +* [Working with Camel and Spring](spring.adoc) +* [Working with Camel and Guice](guice.adoc) +* [Working with Camel and Karaf](karaf.adoc) +* [How do I configure endpoints?](how-do-i-configure-endpoints.adoc) +* [Bean Integration](bean-integration.adoc) +* [Configuring Camel](how-do-i-add-a-component.adoc) +* [Configuring route startup ordering and autostartup] +* [Graceful Shutdown] +* [AsyncProcessorAwaitManager] for insight into the routing engine when it has been forced to block threads while exchanges are being processed asynchronous +* [Error handling in Camel](error-handling-in-camel.adoc) +* [How to use Camel property placeholders](using-propertyplaceholder.adoc) +* [Tutorials] +* [Examples](examples.adoc) +* [Testing](testing.adoc) +* [Xml Configuration] +* [Using CamelProxy] for how to use proxies for clients to easily invoke camel routes without them knowing +* [Camel Maven Plugin] for running Camel from a Maven goal +* [Guice Maven Plugin] for working with [Guice](guice.adoc) +* [Camel Maven
[jira] [Commented] (CAMEL-12605) Enhance the AS2 Component to send and receive encrypted AS2 messages
[ https://issues.apache.org/jira/browse/CAMEL-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653149#comment-16653149 ] ASF GitHub Bot commented on CAMEL-12605: oscerd commented on issue #2568: [CAMEL-12605] Updated signature algorithms supported and refactored API. URL: https://github.com/apache/camel/pull/2568#issuecomment-430527901 Thanks merged on master This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Enhance the AS2 Component to send and receive encrypted AS2 messages > > > Key: CAMEL-12605 > URL: https://issues.apache.org/jira/browse/CAMEL-12605 > Project: Camel > Issue Type: Improvement >Affects Versions: 2.23.0 >Reporter: William Collins >Assignee: William Collins >Priority: Major > > Enhance the AS2 Component to support encrypted AS2 messages per RFC4130 -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-12605) Enhance the AS2 Component to send and receive encrypted AS2 messages
[
https://issues.apache.org/jira/browse/CAMEL-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653150#comment-16653150
]
ASF GitHub Bot commented on CAMEL-12605:
oscerd closed pull request #2568: [CAMEL-12605] Updated signature algorithms
supported and refactored API.
URL: https://github.com/apache/camel/pull/2568
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/components/camel-as2/camel-as2-api/src/main/java/org/apache/camel/component/as2/api/AS2ClientManager.java
b/components/camel-as2/camel-as2-api/src/main/java/org/apache/camel/component/as2/api/AS2ClientManager.java
index 5865efa9434..ecd1f7a9cd5 100644
---
a/components/camel-as2/camel-as2-api/src/main/java/org/apache/camel/component/as2/api/AS2ClientManager.java
+++
b/components/camel-as2/camel-as2-api/src/main/java/org/apache/camel/component/as2/api/AS2ClientManager.java
@@ -29,10 +29,8 @@
import org.apache.camel.component.as2.api.util.SigningUtils;
import org.apache.http.HttpException;
import org.apache.http.HttpResponse;
-import org.apache.http.NameValuePair;
import org.apache.http.entity.ContentType;
import org.apache.http.message.BasicHttpEntityEnclosingRequest;
-import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HttpCoreContext;
import org.apache.http.util.Args;
import org.bouncycastle.cms.CMSEnvelopedDataGenerator;
@@ -123,10 +121,10 @@
public static final String AS2_TO = CAMEL_AS2_CLIENT_PREFIX + "as2-to";
/**
- * The HTTP Context Attribute containing the algorithm name used to sign
EDI
+ * The HTTP Context Attribute containing the algorithm used to sign EDI
* message
*/
-public static final String SIGNING_ALGORITHM_NAME =
CAMEL_AS2_CLIENT_PREFIX + "signing-algorithm-name";
+public static final String SIGNING_ALGORITHM = CAMEL_AS2_CLIENT_PREFIX +
"signing-algorithm";
/**
* The HTTP Context Attribute containing the certificate chain used to sign
@@ -192,6 +190,7 @@ public AS2ClientManager(AS2ClientConnection
as2ClientConnection) {
* @param as2MessageStructure - the structure of AS2 to send; see {@link
AS2MessageStructure}
* @param ediMessageContentType - the content typw of EDI message
* @param ediMessageTransferEncoding - the transfer encoding used to
transport EDI message
+ * @param signingAlgorithm - the algorithm used to sign the message or
null if sending EDI message unsigned
* @param signingCertificateChain - the chain of certificates used to sign
the message or null if sending EDI message unsigned
* @param signingPrivateKey - the private key used to sign EDI message
* @param dispositionNotificationTo - an RFC2822 address to request a
receipt or null if no receipt requested
@@ -211,6 +210,7 @@ public HttpCoreContext send(String ediMessage,
AS2MessageStructure as2MessageStructure,
ContentType ediMessageContentType,
String ediMessageTransferEncoding,
+AS2SignatureAlgorithm signingAlgorithm,
Certificate[] signingCertificateChain,
PrivateKey signingPrivateKey,
String dispositionNotificationTo,
@@ -235,6 +235,7 @@ public HttpCoreContext send(String ediMessage,
httpContext.setAttribute(AS2ClientManager.AS2_MESSAGE_STRUCTURE,
as2MessageStructure);
httpContext.setAttribute(AS2ClientManager.EDI_MESSAGE_CONTENT_TYPE,
ediMessageContentType);
httpContext.setAttribute(AS2ClientManager.EDI_MESSAGE_TRANSFER_ENCODING,
ediMessageTransferEncoding);
+httpContext.setAttribute(AS2ClientManager.SIGNING_ALGORITHM,
signingAlgorithm);
httpContext.setAttribute(AS2ClientManager.SIGNING_CERTIFICATE_CHAIN,
signingCertificateChain);
httpContext.setAttribute(AS2ClientManager.SIGNING_PRIVATE_KEY,
signingPrivateKey);
httpContext.setAttribute(AS2ClientManager.DISPOSITION_NOTIFICATION_TO,
dispositionNotificationTo);
@@ -303,6 +304,11 @@ public HttpCoreContext send(String ediMessage,
}
public AS2SignedDataGenerator createSigningGenerator(HttpCoreContext
httpContext) throws HttpException {
+
+AS2SignatureAlgorithm signatureAlgorithm =
httpContext.getAttribute(SIGNING_ALGORITHM, AS2SignatureAlgorithm.class);
+if (signatureAlgorithm == null) {
+throw new HttpException("Signing algorithm missing");
+}
Certificate[] certificateChain =
httpContext.getAttribute(SIGNING_CERTIFICATE_CHAIN, Certificate[].class);
if (certificateC
