Maybe several standalone brokers are operating on the same database? How many brokers shard the database and what lock mechanism(row lock or lease lock) are you using?
At 2013-07-03 20:21:15,ajay <[email protected]> wrote: >Hi all, >I am getting following Exception when trying to save multiple messages using >activemq in jms session commit. > >ERROR [STDERR] Caused by: java.sql.BatchUpdateException: Violation of >PRIMARY KEY constraint 'PK__ACTIVEMQ__3214EC2707020F21'. Cannot insert >duplicate key in object 'dbo.ACTIVEMQ_MSGS'. >2013-07-03 17:06:02,261 ERROR [STDERR] at >com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.executeBatch(Unknown >Source) >2013-07-03 17:06:02,261 ERROR [STDERR] at >org.jboss.resource.adapter.jdbc.WrappedStatement.executeBatch(WrappedStatement.java:519) >2013-07-03 17:06:02,261 ERROR [STDERR] at >org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:103) >2013-07-03 17:06:02,261 ERROR [STDERR] at >org.apache.activemq.store.jdbc.TransactionContext.executeBatch(TransactionContext.java:81) >2013-07-03 17:06:02,261 ERROR [STDERR] at >org.apache.activemq.store.jdbc.TransactionContext.commit(TransactionContext.java:166) >2013-07-03 17:06:02,261 ERROR [STDERR] ... 18 more > >2013-07-03 17:06:02,263 ERROR [STDERR] Caused by: >javax.transaction.xa.XAException: STORE COMMIT FAILED: Transaction rolled >back. >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.transaction.LocalTransaction.commit(LocalTransaction.java:77) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:173) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:103) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.broker.TransportConnection.processCommitTransactionOnePhase(TransportConnection.java:420) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:100) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) >2013-07-03 17:06:02,263 ERROR [STDERR] at >org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218) >2013-07-03 17:06:02,263 ERROR [STDERR] ... 5 more > >Please let me know any code changes to be made in activemq persistence to >avoid persistence of duplicate messages.Its urgent!!!!!!!! > >activemq table design has primary key with identity still it throws >exception.any configuration changes needs to be made on database table >creation side or any changes in activemq persistence in clusters? >Need ur valuable information. > > >Thanks,, >Ajay.V > > > > > > >-- >View this message in context: >http://activemq.2283324.n4.nabble.com/Activemq-Duplicate-Message-persistence-tp4668835.html >Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
