Skip to content

Instantly share code, notes, and snippets.

@garyhodgson

garyhodgson/narayana_attempt

Created November 30, 2017 22:25
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save garyhodgson/c96bc6c90656c5f1a2af21f95caacf9f to your computer and use it in GitHub Desktop.
Save garyhodgson/c96bc6c90656c5f1a2af21f95caacf9f to your computer and use it in GitHub Desktop.
Download ZIP
Standalone Camel JTA with Narayana attempt - maven output
Raw
narayana_attempt
--- camel-maven-plugin:2.20.0:run (default-cli) @ camel-example-cdi-standalone-jta ---
You can skip tests from the command line using: mvn camel:run -Dmaven.test.skip=true
camel-cdi detected on classpath
Using org.apache.camel.cdi.Main to initiate a CamelContext
Starting Camel ...
23:22:20,290 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Version.<clinit> WELD-000900: 2.4.4 (Final)
Nov 30, 2017 11:22:20 PM org.apache.deltaspike.core.util.ProjectStageProducer initProjectStage
INFO: Computed the following DeltaSpike ProjectStage: Production
23:22:20,490 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Bootstrap.startContainer WELD-000101: Transactional services not available. Injection of @Inject UserTransaction not available. Transactional observers will be invoked synchronously.
23:22:20,689 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Event.checkRequiredTypeAnnotations WELD-000411: Observer method [BackedAnnotatedMethod] protected org.apache.deltaspike.core.impl.exclude.extension.ExcludeExtension.vetoBeans(@Observes ProcessAnnotatedType, BeanManager) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
23:22:20,699 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Event.checkRequiredTypeAnnotations WELD-000411: Observer method [BackedAnnotatedMethod] private org.apache.camel.cdi.CdiCamelExtension.processAnnotatedType(@Observes ProcessAnnotatedType<?>) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
23:22:20,707 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Event.checkRequiredTypeAnnotations WELD-000411: Observer method [BackedAnnotatedMethod] protected org.apache.deltaspike.core.impl.interceptor.GlobalInterceptorExtension.promoteInterceptors(@Observes ProcessAnnotatedType, BeanManager) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
23:22:20,709 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Event.checkRequiredTypeAnnotations WELD-000411: Observer method [BackedAnnotatedMethod] protected org.apache.deltaspike.core.impl.message.MessageBundleExtension.detectInterfaces(@Observes ProcessAnnotatedType) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
23:22:20,711 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Event.checkRequiredTypeAnnotations WELD-000411: Observer method [BackedAnnotatedMethod] public org.apache.deltaspike.core.impl.config.ConfigurationExtension.findDynamicConfigurationBeans(@Observes ProcessAnnotatedType<?>) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
23:22:20,945 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.SupportsJtaTransactionPolicy.transactionManager
23:22:20,948 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.MandatoryJtaTransactionPolicy.transactionManager
23:22:20,956 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.NeverJtaTransactionPolicy.transactionManager
23:22:20,957 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.NotSupportedJtaTransactionPolicy.transactionManager
23:22:20,958 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.JtaTransactionPolicy.transactionManager
23:22:20,982 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.RequiredJtaTransactionPolicy.transactionManager
23:22:20,984 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.RequiresNewJtaTransactionPolicy.transactionManager
23:22:20,986 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.TransactionalJtaTransactionPolicy.transactionManager
23:22:20,989 org.apache.camel.cdi.Main.main() [INFO ] urceInjectReplacementExtension.lambda$addInjectAnnotation$1 @Resource override for field: [BackedAnnotatedField] @Resource protected org.apache.camel.cdi.transaction.NestedJtaTransactionPolicy.transactionManager
23:22:21,025 org.apache.camel.cdi.Main.main() [WARN ] o.j.w.Validator.log WELD-001478: Interceptor class org.apache.deltaspike.core.impl.throttling.ThrottledInterceptor is enabled for the application and for the bean archive /D:/Tools/Maven/.m2/repository/org/apache/deltaspike/core/deltaspike-core-impl/1.8.0/deltaspike-core-impl-1.8.0.jar. It will only be invoked in the @Priority part of the chain.
23:22:21,026 org.apache.camel.cdi.Main.main() [WARN ] o.j.w.Validator.log WELD-001478: Interceptor class org.apache.deltaspike.core.impl.lock.LockedInterceptor is enabled for the application and for the bean archive /D:/Tools/Maven/.m2/repository/org/apache/deltaspike/core/deltaspike-core-impl/1.8.0/deltaspike-core-impl-1.8.0.jar. It will only be invoked in the @Priority part of the chain.
23:22:21,026 org.apache.camel.cdi.Main.main() [WARN ] o.j.w.Validator.log WELD-001478: Interceptor class org.apache.deltaspike.core.impl.future.FutureableInterceptor is enabled for the application and for the bean archive /D:/Tools/Maven/.m2/repository/org/apache/deltaspike/core/deltaspike-core-impl/1.8.0/deltaspike-core-impl-1.8.0.jar. It will only be invoked in the @Priority part of the chain.
23:22:21,617 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.i.c.DefaultTypeConverter.doStart Type converters loaded (core: 192, classpath: 4)
23:22:21,663 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.c.CdiCamelExtension.afterDeploymentValidation Camel CDI is starting Camel context [camel-1]
23:22:21,665 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.i.DefaultCamelContext.start Apache Camel 2.20.0 (CamelContext: camel-1) is starting
23:22:21,667 org.apache.camel.cdi.Main.main() [INFO ] .c.m.ManagedManagementStrategy.doStart JMX is enabled
23:22:21,866 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.i.DefaultCamelContext.doStartCamel StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
23:22:22,022 org.apache.camel.cdi.Main.main() [INFO ] o.a.a.b.BrokerService.doStartPersistenceAdapter Using Persistence Adapter: MemoryPersistenceAdapter
23:22:22,053 JMX connector [INFO ] o.a.a.b.j.ManagementContext.run JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
23:22:22,174 org.apache.camel.cdi.Main.main() [INFO ] o.a.a.b.BrokerService.doStartBroker Apache ActiveMQ 5.15.2 (localhost, ID:garyhodgson-PC-62188-1512080542047-0:1) is starting
23:22:22,182 org.apache.camel.cdi.Main.main() [INFO ] o.a.a.b.BrokerService.doStartBroker Apache ActiveMQ 5.15.2 (localhost, ID:garyhodgson-PC-62188-1512080542047-0:1) started
23:22:22,182 org.apache.camel.cdi.Main.main() [INFO ] o.a.a.b.BrokerService.doStartBroker For help or more information please see: http://activemq.apache.org
23:22:22,186 org.apache.camel.cdi.Main.main() [WARN ] o.a.a.b.BrokerService.checkUsageLimit Temporary Store limit is 51200 mb (current store usage is 0 mb). The data directory: C:\Users\garyhodgson\Desktop\camel-example-cdi-standalone-jta only has 25049 mb of usable space. - resetting to maximum available disk space: 25049 mb
23:22:22,214 org.apache.camel.cdi.Main.main() [INFO ] o.a.a.b.TransportConnector.start Connector vm://localhost started
23:22:22,250 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.i.DefaultCamelContext.doStartOrResumeRouteConsumers Route: test started and consuming from: activemq://inbound?transacted=true
23:22:22,250 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.i.DefaultCamelContext.start Total 1 routes, of which 1 are started
23:22:22,251 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.i.DefaultCamelContext.start Apache Camel 2.20.0 (CamelContext: camel-1) started in 0.587 seconds
23:22:22,289 org.apache.camel.cdi.Main.main() [INFO ] o.j.w.Bootstrap.fireContainerInitializedEvent WELD-ENV-002003: Weld SE container ba2cc9d0-4913-4216-87a5-9709d928957e initialized
23:22:22,289 Camel (camel-1) thread #2 - JmsConsumer[inbound] [INFO ] o.s.t.j.JtaTransactionManager.checkUserTransactionAndTransactionManager Using JTA UserTransaction: Transaction: unknown
23:22:22,291 Camel (camel-1) thread #2 - JmsConsumer[inbound] [INFO ] o.s.t.j.JtaTransactionManager.checkUserTransactionAndTransactionManager Using JTA TransactionManager: Transaction: unknown
23:22:22,293 org.apache.camel.cdi.Main.main() [INFO ] o.a.c.e.c.MyRoutes.onContextStarted ContainerInitialized: ContainerInitialized event for container with ID: ba2cc9d0-4913-4216-87a5-9709d928957e
23:22:22,329 Camel (camel-1) thread #2 - JmsConsumer[inbound] [DEBUG] c.a.a.arjuna.addService com.arjuna.ats.arjuna.recovery.ActionStatusService starting
23:22:22,331 Camel (camel-1) thread #2 - JmsConsumer[inbound] [DEBUG] c.a.a.arjuna.<init> TransactionStatusManagerItem host: {0} port: {1}
23:22:22,338 Camel (camel-1) thread #2 - JmsConsumer[inbound] [INFO ] c.a.a.arjuna.start ARJUNA012170: TransactionStatusManager started on port 62191 and host 127.0.0.1 with service com.arjuna.ats.arjuna.recovery.ActionStatusService
23:22:22,398 Camel (camel-1) thread #2 - JmsConsumer[inbound] [INFO ] out.log Exchange[ExchangePattern: InOnly, BodyType: String, Body: message 3 - ok]
23:22:22,408 Camel (camel-1) thread #2 - JmsConsumer[inbound] [WARN ] .c.c.t.TransactionErrorHandler.logTransactionRollback Transaction rollback (0x7001dc5f) redelivered(false) for (MessageId: ID:garyhodgson-PC-62188-1512080542047-4:3:1:1:1 on ExchangeId: ID-garyhodgson-PC-1512080541389-0-4) caught: Triggering Rollback
23:22:22,410 Camel (camel-1) thread #2 - JmsConsumer[inbound] [ERROR] .c.c.t.TransactionErrorHandler.log Failed delivery for (MessageId: ID:garyhodgson-PC-62188-1512080542047-4:3:1:1:1 on ExchangeId: ID-garyhodgson-PC-1512080541389-0-4). Exhausted after delivery attempt: 1 caught: java.lang.IllegalStateException: Triggering Rollback
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor Elapsed (ms)
[test ] [test ] [activemq://inbound?transacted=true ] [ 5]
[test ] [transacted1 ] [transacted ] [ 4]
[test ] [to1 ] [activemq:middle?transacted=true ] [ 3]
[test ] [process1 ] [Processor@0x429c58d1 ] [ 0]
23:22:22,411 Camel (camel-1) thread #2 - JmsConsumer[inbound] [WARN ] .c.c.j.EndpointMessageListener.log Execution of JMS message listener failed. Caused by: [org.apache.camel.RuntimeCamelException - java.lang.IllegalStateException: Triggering Rollback]
org.apache.camel.RuntimeCamelException: java.lang.IllegalStateException: Triggering Rollback
at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1831) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.component.jms.EndpointMessageListener$EndpointMessageListenerAsyncCallback.done(EndpointMessageListener.java:195) ~[camel-jms-2.20.0.jar:2.20.0]
at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:116) ~[camel-jms-2.20.0.jar:2.20.0]
at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:721) ~[spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:681) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:651) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:317) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:235) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1166) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1158) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1055) [spring-jms-4.3.11.RELEASE.jar:4.3.11.RELEASE]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_121]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_121]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]
Caused by: java.lang.IllegalStateException: Triggering Rollback
at org.apache.camel.example.cdi.MyRoutes.lambda$configure$0(MyRoutes.java:55) ~[classes/:?]
at org.apache.camel.processor.DelegateSyncProcessor.process(DelegateSyncProcessor.java:76) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:176) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionErrorHandler.processByErrorHandler(TransactionErrorHandler.java:228) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionErrorHandler$1.run(TransactionErrorHandler.java:189) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionalJtaTransactionPolicy.runWithTransaction(TransactionalJtaTransactionPolicy.java:42) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.RequiredJtaTransactionPolicy.run(RequiredJtaTransactionPolicy.java:26) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionErrorHandler.doInTransactionTemplate(TransactionErrorHandler.java:179) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionErrorHandler.processInTransaction(TransactionErrorHandler.java:131) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionErrorHandler.process(TransactionErrorHandler.java:101) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.cdi.transaction.TransactionErrorHandler.process(TransactionErrorHandler.java:109) ~[camel-cdi-2.20.0.jar:2.20.0]
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:97) ~[camel-core-2.20.0.jar:2.20.0]
at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:112) ~[camel-jms-2.20.0.jar:2.20.0]
... 11 more
inbound QueueSize = 0
middle QueueSize = 2
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment