[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] [Resolved] (AMQ-4636) JDBCPersistence DB stopped during message send; JMSException is sent ba
From:       "Gary Tully (JIRA)" <jira () apache ! org>
Date:       2013-07-30 20:35:50
Message-ID: JIRA.12658468.1374135554394.139364.1375216550557 () arcas
[Download RAW message or body]


     [ https://issues.apache.org/jira/browse/AMQ-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel \
]

Gary Tully resolved AMQ-4636.
-----------------------------

       Resolution: Fixed
    Fix Version/s: 5.9.0

This is fixed as a byproduct of https://issues.apache.org/jira/browse/AMQ-4643 

The TransactionContext.close now correctly delegates to the IOExceptionHandler which \
handles the transaction commit/rollback failure cases  
> JDBCPersistence DB stopped during message send; JMSException is sent back to client \
>                 rather than shutting down connection
> ------------------------------------------------------------------------------------------------------------------------
>  
> Key: AMQ-4636
> URL: https://issues.apache.org/jira/browse/AMQ-4636
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: 5.8.0
> Environment: tested on trunk.
> Reporter: Pat Fox
> Assignee: Gary Tully
> Fix For: 5.9.0
> 
> Attachments: AMQ4636Test.java
> 
> 
> Broker is configured to use JDBCIOExceptionHandler.
> When the JDBCPersistence DB is stopped during a message send the broker returns the \
> following javax.jms.JMSException back to the client rather than closing the \
> connection. This results in the client having to deal with the exception instead of \
> the failover transport having to deal with a connection loss and redeliver the \
> message. Failover transport and transport connection loss seems to be the approach \
> used when other SQL exceptions are thrown. {code}
> Exception received on client side:
> javax.jms.JMSException: ORA-01089: immediate shutdown in progress - no operation
> s are permitted
> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSuppo
> rt.java:54)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnect
> ion.java:1391)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnect
> ion.java:1319)
> at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1798)
> at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProdu
> cer.java:289)
> at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProdu
> cer.java:224)
> at org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessa
> geProducerSupport.java:241)
> at com.acme.MyPublisher.doIt(MyPublisher.java:50)
> at com.acme.MyPublisher.main(MyPublisher.java:26)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.
> java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces
> sorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297)
> at java.lang.Thread.run(Thread.java:662)
> Caused by: java.io.IOException: ORA-01089: immediate shutdown in progress - no o
> perations are permitted
> at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport
> .java:45)
> at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionCo
> ntext.java:141)
> at org.apache.activemq.store.jdbc.JDBCMessageStore.addMessage(JDBCMessag
> eStore.java:129)
> at org.apache.activemq.store.memory.MemoryTransactionStore.addMessage(Me
> moryTransactionStore.java:327)
> at org.apache.activemq.store.memory.MemoryTransactionStore$2.asyncAddTop
> icMessage(MemoryTransactionStore.java:190)
> at org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:471)
> at org.apache.activemq.broker.region.Topic.send(Topic.java:435)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.
> java:406)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java
> > 392)
> at org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegion
> Broker.java:282)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
> at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeD
> estinationBroker.java:96)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.j
> ava:317)
> at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilt
> er.java:135)
> at org.apache.activemq.broker.TransportConnection.processMessage(Transpo
> rtConnection.java:499)
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.jav
> a:749)
> at org.apache.activemq.broker.TransportConnection.service(TransportConne
> ction.java:329)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC
> onnection.java:184)
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport
> .java:50)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireForm
> atNegotiator.java:113)
> at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(Abs
> tractInactivityMonitor.java:288)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSup
> port.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
> a:214)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
> 196)
> ... 1 more
> Caused by: java.lang.Throwable: java.sql.BatchUpdateException: ORA-01089: immedi
> ate shutdown in progress - no operations are permitted
> at oracle.jdbc.driver.OraclePreparedStatement.executeBatch(OraclePrepare
> dStatement.java:10296)
> at oracle.jdbc.driver.OracleStatementWrapper.executeBatch(OracleStatemen
> tWrapper.java:216)
> at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeBatch(NewPr
> oxyPreparedStatement.java:1723)
> at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(Transa
> ctionContext.java:106)
> at org.apache.activemq.store.jdbc.TransactionContext.executeBatch(Transa
> ctionContext.java:84)
> at org.apache.activemq.store.jdbc.TransactionContext.close(TransactionCo
> ntext.java:132)
> {code}
> Will attach a test case soon.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira


[prev in list] [next in list] [prev in thread] [next in thread]