activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From klate <Klaus.Terj...@bank-verlag.de>
Subject Re: ActiveMQ and DB2
Date Mon, 10 Apr 2006 13:36:17 GMT

Hello,

I work with the Snapshot from  06-Apr-2006 00:12

and it doesn't work

<broker brokerName="faxBrocker" useJmx="true">

 <jdbcPersistenceAdapter
class="org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter"
dataSource="#db2-ds">

 <bean id="db2-ds" class="org.apache.commons.dbcp.BasicDataSource">
     <property name="driverClassName" value="com.ibm.db2.jcc.DB2Driver"/>
     <property name="url" value="jdbc:db2://192.168.18.92:50030/deb_osqa"/>
     <property name="username" value="USER"/>
     <property name="password" value="PASSWORD"/>   
   </bean>

 <transportConnectors>
      <transportConnector uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
    	<!--transportConnector uri="tcp://localhost:61616"/-->
    	<transportConnector uri="stomp://localhost:61617"/> 
    </transportConnectors>

    <networkConnectors>
      <!-- by default just auto discover the other brokers -->
        <networkConnector name="default" uri="multicast://default"/> 
    </networkConnectors>



I send a Message with a Blob (PDF-Document)  and when i try to Consume the
Message
it throws the following Exception:

INFO  Service                        - Sync error occurred:
java.io.IOException: Non-atomic batch failure.  The batch was submitted, but
at least one ex
ception 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 g
etNextException() 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:74)
        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:253)
        at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:196)
        at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:322)
        at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
        at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:109)
        at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
        at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:121)
        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:139)
        at java.lang.Thread.run(Thread.java:534)
Caused by: com.ibm.db2.jcc.c.vd: 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 com.ibm.db2.jcc.c.i.a(i.java:390)
        at com.ibm.db2.jcc.c.ad.b(ad.java:2865)
        at com.ibm.db2.jcc.c.ad.a(ad.java:2634)
        at com.ibm.db2.jcc.c.ad.executeBatch(ad.java:2446)
        at com.ibm.db2.jcc.c.ad.executeBatch(ad.java:1331)
        at
org.apache.commons.dbcp.DelegatingStatement.executeBatch(DelegatingStatement.java:205)
        at
org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:92)
        at
org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:71)
        at
org.apache.activemq.store.jdbc.TransactionContext.close(TransactionContext.java:107)
        ... 21 more


Best Regards 

Klaus Terjung  
 
--
View this message in context: http://www.nabble.com/ActiveMQ-and-DB2-t1406269.html#a3841906
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message