camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-7668) @Consume may restart during a shutdown event
Date Tue, 26 Aug 2014 08:47:57 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14110500#comment-14110500
] 

Claus Ibsen commented on CAMEL-7668:
------------------------------------

This is the pojo example btw that is shipped with Apache Camel.

> @Consume may restart during a shutdown event
> --------------------------------------------
>
>                 Key: CAMEL-7668
>                 URL: https://issues.apache.org/jira/browse/CAMEL-7668
>             Project: Camel
>          Issue Type: Improvement
>          Components: camel-core
>            Reporter: Claus Ibsen
>            Assignee: Claus Ibsen
>            Priority: Minor
>             Fix For: 2.14.0
>
>
> When using POJO consuming and we shutdown CamelContext and if by chance something hangs,
such as the JMS shutdown (see other tickets) then the file endpoint may be stopped but the
POJO consumer is still running (not shutdown) and this causes the idempotent repo to reset
its state, and the POJO consumer will then pickup the same files again.
> eg as demonstrated by the pojo example
> {code}
> 2014-08-07 14:17:49,909 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:49,945 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:49,950 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:49,955 [sonnel.records]] INFO  XPathBuilder                   - Created
default XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@3e9037f9
> 2014-08-07 14:17:49,996 [sonnel.records]] INFO  DistributeRecordsBean          - Person
is from EMEA region
> 2014-08-07 14:17:50,008 [sonnel.records]] INFO  DistributeRecordsBean          - Person
is from AMER region
> 2014-08-07 14:17:50,014 [sonnel.records]] INFO  DistributeRecordsBean          - Person
is from AMER region
> ^C2014-08-07 14:17:52,237 [Thread-5       ] INFO  MainSupport$HangupInterceptor  - Received
hang up - stopping the main instance.
> 2014-08-07 14:17:52,237 [Thread-5       ] INFO  MainSupport                    - Apache
Camel 2.14-SNAPSHOT stopping
> 2014-08-07 14:17:52,237 [Thread-5       ] INFO  ClassPathXmlApplicationContext - Closing
org.springframework.context.support.ClassPathXmlApplicationContext@1f361707: startup date
[Thu Aug 07 14:17:46 CEST 2014]; root of context hierarchy
> 2014-08-07 14:17:52,238 [Thread-5       ] INFO  SpringCamelContext             - Apache
Camel 2.14-SNAPSHOT (CamelContext: camel-1) is shutting down
> 2014-08-07 14:17:52,242 [sonnel.records]] WARN  ultJmsMessageListenerContainer - Setup
of JMS message listener invoker failed for destination 'personnel.records' - trying to recover.
Cause: The Session is closed
> 2014-08-07 14:17:52,247 [sonnel.records]] ERROR ultJmsMessageListenerContainer - Could
not refresh JMS Connection for destination 'personnel.records' - retrying in 5000 ms. Cause:
null
> 2014-08-07 14:17:52,466 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:52,467 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:52,469 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:52,469 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:52,470 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:52,470 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:52,976 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:52,977 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:52,978 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:52,979 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:52,980 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:52,980 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:53,484 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:53,485 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:53,487 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:53,487 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:53,489 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:53,489 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:53,993 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:53,994 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:53,995 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:53,996 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:53,997 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:53,997 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:54,500 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:54,500 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:54,502 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:54,502 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:54,503 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:54,504 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:55,007 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:55,008 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:55,009 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:55,009 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:55,011 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:55,011 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:55,515 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:55,515 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:55,517 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:55,517 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:55,518 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:55,518 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:56,021 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:56,022 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:56,023 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:56,024 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:56,025 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:56,026 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:56,529 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:56,530 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:56,531 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:56,532 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:56,533 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:56,533 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:57,035 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message1.xml
> 2014-08-07 14:17:57,036 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message1.xml]
> 2014-08-07 14:17:57,037 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message2.xml
> 2014-08-07 14:17:57,037 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message2.xml]
> 2014-08-07 14:17:57,038 [file://src/data] INFO  SendFileRecordsToQueueBean     - Incoming
file: message3.xml
> 2014-08-07 14:17:57,038 [file://src/data] WARN  GenericFileOnCompletion        - Rollback
file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@693a9769
for file: GenericFile[message3.xml]
> 2014-08-07 14:17:57,251 [Thread-5       ] INFO  SpringCamelContext             - Apache
Camel 2.14-SNAPSHOT (CamelContext: camel-1) uptime 8.256 seconds
> 2014-08-07 14:17:57,252 [Thread-5       ] INFO  SpringCamelContext             - Apache
Camel 2.14-SNAPSHOT (CamelContext: camel-1) is shutdown in 5.013 seconds
> 2014-08-07 14:17:57,252 [Thread-5       ] INFO  DefaultListableBeanFactory     - Destroying
singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@4e358ab7:
defining beans [broker,activemq,org.apache.camel.example.pojo_messaging.SendFileRecordsToQueueBean#0,org.apache.camel.example.pojo_messaging.DistributeRecordsBean#0,template,consumerTemplate,camel-1:beanPostProcessor,camel-1];
root of factory hierarchy
> 2014-08-07 14:17:57,253 [Thread-5       ] INFO  BrokerService                  - Apache
ActiveMQ 5.11-SNAPSHOT (myBroker, ID:davsclaus.air-50520-1407413868345-0:1) is shutting down
> 2014-08-07 14:17:57,254 [Thread-5       ] INFO  TransportConnector             - Connector
vm://myBroker stopped
> 2014-08-07 14:17:57,264 [Thread-5       ] INFO  BrokerService                  - Apache
ActiveMQ 5.11-SNAPSHOT (myBroker, ID:davsclaus.air-50520-1407413868345-0:1) uptime 9.268 seconds
> 2014-08-07 14:17:57,264 [Thread-5       ] INFO  BrokerService                  - Apache
ActiveMQ 5.11-SNAPSHOT (myBroker, ID:davsclaus.air-50520-1407413868345-0:1) is shutdown
> {code}



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message