activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ajay <ajay.v...@exterro.com>
Subject Activemq - Duplicate Message persistence
Date Wed, 03 Jul 2013 12:21:15 GMT
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.

Mime
View raw message