ActiveMQ 4 exception with with DB2 ------------------------------------ Key: AMQ-679 URL: https://issues.apache.org/activemq/browse/AMQ-679 Project: ActiveMQ Type: Bug
Components: Message Store Versions: 4.0 RC 2 Environment: IBM Blade JS20 AIX 5.3 DB2 DataBase 8.2 Driver 2.5.33 Configuration: <jdbcPersistenceAdapter class="org.activemq.store.jdbc.adapter.DefaultJDBCAdapter" dataSource= "#db2-ds"/> <bean id="db2datasource" class="org.apache.commons.dbcp.BasicDataSource"> <property name="driverClassName" value="com.ibm.db2.jcc.DB2Driver"/> <property name="url" value="URL"/> <property name="username" value="USER"/> <property name="password" value="PASS"/> </bean> Reporter: klaus terjung Priority: Blocker If start broker i get this message: WARNING: Database driver NOT recognized: [ibm_db2_jdbc_universal_driver_architecture]. Will use default JDBC implementation. But this seems to be o.k. so far, because after starting the broker, two new tables (activemq_msgs/acks) get created. Testing a Consumer to receive Messages the broker throws this exception: 2006-04-05 17:13:03,304 [.168.1.52:52134] INFO Service - Sync error occurred: java.io.IOException: Non-atomic batch failure. The batch was submitted, but at least one exception occurred on an individual member of the batch. Use getNextException() to retrieve the exceptions for specific batched elements. java.io.IOException: Non-atomic batch failure. The batch was submitted, but at least one exception occurred on an individual member of the batch. Use getNextException() to retrieve the exceptions for specific batched elements. at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:42) at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:125) at org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessageStore.java:73) at org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(MemoryTransactionStore.java:223) at org.apache.activemq.store.memory.MemoryTransactionStore$1.addMessage(MemoryTransactionStore.java:116) at org.apache.activemq.broker.region.Queue.send(Queue.java:246) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:196) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:307) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:108) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:120) at org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:346) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:590) at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:196) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:88) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:70) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136) at java.lang.Thread.run(Thread.java:570) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira