API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Nov 18th, 2016
208
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 14.43 KB | None | 0 0
raw download clone embed print report
  1. public static void main(String[] args) throws Exception {
  2.  
  3.  
  4. Configuration BTMconfig = TransactionManagerServices.getConfiguration();
  5. BTMconfig.setServerId("spring-btm");
  6. BitronixTransactionManager BitronixTM = TransactionManagerServices.getTransactionManager();
  7.  
  8. JtaTransactionManager JTAtm = new JtaTransactionManager();
  9. JTAtm.setUserTransaction(BitronixTM);
  10. JTAtm.setTransactionManager(BitronixTM);
  11.  
  12. PoolingDataSource xaDataSource = new PoolingDataSource();
  13.  
  14. xaDataSource.setClassName("org.apache.derby.jdbc.EmbeddedXADataSource");
  15. xaDataSource.setUniqueName("xaDataSource");
  16. xaDataSource.setMinPoolSize(1);
  17. xaDataSource.setMaxPoolSize(5);
  18. xaDataSource.setAllowLocalTransactions(true);
  19.  
  20. Properties xaDataSourceProp = new Properties();
  21. xaDataSourceProp.put("DatabaseName","DerbyDB");
  22. xaDataSourceProp.put("CreateDatabase","true");
  23. xaDataSourceProp.put("DataSourceName","xaDataSource");
  24.  
  25. xaDataSource.setDriverProperties(xaDataSourceProp);
  26.  
  27. xaDataSource.init();
  28.  
  29. SimpleRegistry registry = new SimpleRegistry();
  30. registry.put("transactionManager", JTAtm);
  31. registry.put("xaDataSource", xaDataSource);
  32.  
  33. CamelContext camelContext = new DefaultCamelContext(registry);
  34.  
  35.  
  36. camelContext.addRoutes(new RouteBuilder(){
  37.  
  38. @Override
  39. public void configure() throws Exception {
  40. from("file:data/inbox?noop=true").
  41. transacted().
  42. process(new ToJdbcProcessor()).
  43. to("jdbc:xaDataSource");
  44. }
  45. });
  46.  
  47. camelContext.start();
  48. Thread.sleep(3000);
  49.  
  50. }
  51.  
  52. [ thread #0 - file://data/inbox] JdbcProducer WARN Error occurred during jdbc rollback. This exception will be ignored.
  53. java.sql.SQLException: cannot rollback a resource enlisted in a global transaction
  54. at bitronix.tm.resource.jdbc.JdbcConnectionHandle.rollback(JdbcConnectionHandle.java:120)[btm-2.1.4.jar:2.1.4]
  55. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)[:1.8.0_111]
  56. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)[:1.8.0_111]
  57. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.8.0_111]
  58. at java.lang.reflect.Method.invoke(Method.java:498)[:1.8.0_111]
  59. at bitronix.tm.resource.jdbc.BaseProxyHandlerClass.invoke(BaseProxyHandlerClass.java:64)[btm-2.1.4.jar:2.1.4]
  60. at com.sun.proxy.$Proxy16.rollback(Unknown Source)[:]
  61. at org.apache.camel.component.jdbc.JdbcProducer.processingSqlBySettingAutoCommit(JdbcProducer.java:92)[camel-jdbc-2.18.0.jar:2.18.0]
  62. at org.apache.camel.component.jdbc.JdbcProducer.process(JdbcProducer.java:67)[camel-jdbc-2.18.0.jar:2.18.0]
  63. at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.18.0.jar:2.18.0]
  64. at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)[camel-core-2.18.0.jar:2.18.0]
  65. at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)[camel-core-2.18.0.jar:2.18.0]
  66. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)[camel-core-2.18.0.jar:2.18.0]
  67. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:400)[camel-core-2.18.0.jar:2.18.0]
  68. at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:172)[camel-core-2.18.0.jar:2.18.0]
  69. at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)[camel-core-2.18.0.jar:2.18.0]
  70. at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)[camel-core-2.18.0.jar:2.18.0]
  71. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)[camel-core-2.18.0.jar:2.18.0]
  72. at org.apache.camel.spring.spi.TransactionErrorHandler.processByErrorHandler(TransactionErrorHandler.java:220)[camel-spring-2.18.0.jar:2.18.0]
  73. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:101)[camel-spring-2.18.0.jar:2.18.0]
  74. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:114)[camel-spring-2.18.0.jar:2.18.0]
  75. at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)[camel-core-2.18.0.jar:2.18.0]
  76. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)[camel-core-2.18.0.jar:2.18.0]
  77. at org.apache.camel.spring.spi.TransactionErrorHandler.processByErrorHandler(TransactionErrorHandler.java:220)[camel-spring-2.18.0.jar:2.18.0]
  78. at org.apache.camel.spring.spi.TransactionErrorHandler$1.doInTransactionWithoutResult(TransactionErrorHandler.java:183)[camel-spring-2.18.0.jar:2.18.0]
  79. at org.springframework.transaction.support.TransactionCallbackWithoutResult.doInTransaction(TransactionCallbackWithoutResult.java:34)[spring-tx-4.3.3.RELEASE.jar:4.3.3.RELEASE]
  80. at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:133)[spring-tx-4.3.3.RELEASE.jar:4.3.3.RELEASE]
  81. at org.apache.camel.spring.spi.TransactionErrorHandler.doInTransactionTemplate(TransactionErrorHandler.java:176)[camel-spring-2.18.0.jar:2.18.0]
  82. at org.apache.camel.spring.spi.TransactionErrorHandler.processInTransaction(TransactionErrorHandler.java:136)[camel-spring-2.18.0.jar:2.18.0]
  83. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:105)[camel-spring-2.18.0.jar:2.18.0]
  84. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:114)[camel-spring-2.18.0.jar:2.18.0]
  85. at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)[camel-core-2.18.0.jar:2.18.0]
  86. at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)[camel-core-2.18.0.jar:2.18.0]
  87. at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:460)[camel-core-2.18.0.jar:2.18.0]
  88. at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:227)[camel-core-2.18.0.jar:2.18.0]
  89. at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:191)[camel-core-2.18.0.jar:2.18.0]
  90. at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:175)[camel-core-2.18.0.jar:2.18.0]
  91. at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:102)[camel-core-2.18.0.jar:2.18.0]
  92. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)[:1.8.0_111]
  93. at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)[:1.8.0_111]
  94. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)[:1.8.0_111]
  95. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)[:1.8.0_111]
  96. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)[:1.8.0_111]
  97. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)[:1.8.0_111]
  98. at java.lang.Thread.run(Thread.java:745)[:1.8.0_111]
  99. [ thread #0 - file://data/inbox] DefaultErrorHandler ERROR Failed delivery for (MessageId: ID-office11238-50617-1479470669103-0-3 on ExchangeId: ID-office11238-50617-1479470669103-0-2). Exhausted after delivery attempt: 1 caught: java.sql.SQLException: cannot commit a resource enlisted in a global transaction
  100.  
  101. Message History
  102. ---------------------------------------------------------------------------------------------------------------------------------------
  103. RouteId ProcessorId Processor Elapsed (ms)
  104. [route1 ] [route1 ] [file://data/inbox?noop=true ] [ 211]
  105. [route1 ] [transacted1 ] [transacted ] [ 208]
  106. [route1 ] [process1 ] [Processor@0x39502c11 ] [ 1]
  107. [route1 ] [to1 ] [jdbc:xaDataSource ] [ 182]
  108.  
  109. Stacktrace
  110. ---------------------------------------------------------------------------------------------------------------------------------------
  111. java.sql.SQLException: cannot commit a resource enlisted in a global transaction
  112. at bitronix.tm.resource.jdbc.JdbcConnectionHandle.commit(JdbcConnectionHandle.java:111)[btm-2.1.4.jar:2.1.4]
  113. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)[:1.8.0_111]
  114. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)[:1.8.0_111]
  115. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.8.0_111]
  116. at java.lang.reflect.Method.invoke(Method.java:498)[:1.8.0_111]
  117. at bitronix.tm.resource.jdbc.BaseProxyHandlerClass.invoke(BaseProxyHandlerClass.java:64)[btm-2.1.4.jar:2.1.4]
  118. at com.sun.proxy.$Proxy16.commit(Unknown Source)[:]
  119. at org.apache.camel.component.jdbc.JdbcProducer.processingSqlBySettingAutoCommit(JdbcProducer.java:88)[camel-jdbc-2.18.0.jar:2.18.0]
  120. at org.apache.camel.component.jdbc.JdbcProducer.process(JdbcProducer.java:67)[camel-jdbc-2.18.0.jar:2.18.0]
  121. at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.18.0.jar:2.18.0]
  122. at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)[camel-core-2.18.0.jar:2.18.0]
  123. at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)[camel-core-2.18.0.jar:2.18.0]
  124. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)[camel-core-2.18.0.jar:2.18.0]
  125. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:400)[camel-core-2.18.0.jar:2.18.0]
  126. at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:172)[camel-core-2.18.0.jar:2.18.0]
  127. at org.apache.camel.processor.Pipeline.process(Pipeline.java:120)[camel-core-2.18.0.jar:2.18.0]
  128. at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)[camel-core-2.18.0.jar:2.18.0]
  129. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)[camel-core-2.18.0.jar:2.18.0]
  130. at org.apache.camel.spring.spi.TransactionErrorHandler.processByErrorHandler(TransactionErrorHandler.java:220)[camel-spring-2.18.0.jar:2.18.0]
  131. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:101)[camel-spring-2.18.0.jar:2.18.0]
  132. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:114)[camel-spring-2.18.0.jar:2.18.0]
  133. at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)[camel-core-2.18.0.jar:2.18.0]
  134. at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:542)[camel-core-2.18.0.jar:2.18.0]
  135. at org.apache.camel.spring.spi.TransactionErrorHandler.processByErrorHandler(TransactionErrorHandler.java:220)[camel-spring-2.18.0.jar:2.18.0]
  136. at org.apache.camel.spring.spi.TransactionErrorHandler$1.doInTransactionWithoutResult(TransactionErrorHandler.java:183)[camel-spring-2.18.0.jar:2.18.0]
  137. at org.springframework.transaction.support.TransactionCallbackWithoutResult.doInTransaction(TransactionCallbackWithoutResult.java:34)[spring-tx-4.3.3.RELEASE.jar:4.3.3.RELEASE]
  138. at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:133)[spring-tx-4.3.3.RELEASE.jar:4.3.3.RELEASE]
  139. at org.apache.camel.spring.spi.TransactionErrorHandler.doInTransactionTemplate(TransactionErrorHandler.java:176)[camel-spring-2.18.0.jar:2.18.0]
  140. at org.apache.camel.spring.spi.TransactionErrorHandler.processInTransaction(TransactionErrorHandler.java:136)[camel-spring-2.18.0.jar:2.18.0]
  141. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:105)[camel-spring-2.18.0.jar:2.18.0]
  142. at org.apache.camel.spring.spi.TransactionErrorHandler.process(TransactionErrorHandler.java:114)[camel-spring-2.18.0.jar:2.18.0]
  143. at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)[camel-core-2.18.0.jar:2.18.0]
  144. at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:197)[camel-core-2.18.0.jar:2.18.0]
  145. at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:460)[camel-core-2.18.0.jar:2.18.0]
  146. at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:227)[camel-core-2.18.0.jar:2.18.0]
  147. at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:191)[camel-core-2.18.0.jar:2.18.0]
  148. at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:175)[camel-core-2.18.0.jar:2.18.0]
  149. at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:102)[camel-core-2.18.0.jar:2.18.0]
  150. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)[:1.8.0_111]
  151. at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)[:1.8.0_111]
  152. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)[:1.8.0_111]
  153. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)[:1.8.0_111]
  154. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)[:1.8.0_111]
  155. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)[:1.8.0_111]
  156. at java.lang.Thread.run(Thread.java:745)[:1.8.0_111]
  157. [ thread #0 - file://data/inbox] TransactionErrorHandler WARN Transaction rollback (0x5bc9ba1d) redelivered(unknown) for (MessageId: ID-office11238-50617-1479470669103-0-1 on ExchangeId: ID-office11238-50617-1479470669103-0-2) caught: java.sql.SQLException: cannot commit a resource enlisted in a global transaction
  158. [ thread #0 - file://data/inbox] GenericFileOnCompletion WARN Rollback file strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@11388081 for file: GenericFile[1.txt]
  159. [ thread #0 - file://data/inbox] JdbcProducer WARN Error occurred during jdbc rollback. This exception will be ignored.
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!