activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From SuoNayi <suonayi2...@163.com>
Subject Re:Activemq - Duplicate Message persistence
Date Thu, 04 Jul 2013 05:10:07 GMT
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 <ajay.vasu@exterro.com> 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.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message