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
