activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: Failed network connector can not be re-established
Date Wed, 09 Mar 2016 14:30:52 GMT
"JDBC Failure: Borrow prepareStatement from pool failed"

Your problem is in the JDBC store (specifically the connection pool), whose
configuration you didn't post or tell us anything about.

One possible workaround would be to simply tell the DataSource to not pool
prepared statements via
https://commons.apache.org/proper/commons-dbcp/api-1.4/org/apache/commons/dbcp/BasicDataSource.html#poolPreparedStatements
.
On Mar 8, 2016 9:24 PM, "alt_alt" <alt_alt@163.com> wrote:

> *Configuration for network connector:
> *
> <networkConnector name="external01_01" conduitSubscriptions="false"
> uri="static://(tcp://10.102.44.181:61616)" userName="MQ-PRD-ADMIN"
> password="$
> {connector.password}
> ">
> <excludedDestinations>
> <topic physicalName="VirtualTopic.>"/>
> </excludedDestinations>
> </networkConnector>
> *log:
> *2016-03-03 14:41:13,070 | WARN | JDBC Failure: Borrow prepareStatement
> from
> pool failed | org.apache.activemq.store.jdbc.JDBCPersistenceAdapter |
> ActiveMQ Transport: tcp://10.102.44.181:61616@38805
> org.apache.commons.dbcp.SQLNestedException: Borrow prepareStatement from
> pool failed
> at
>
> org.apache.commons.dbcp.PoolingConnection.prepareStatement(PoolingConnection.java:113)[commons-dbcp-1.4.jar:1.4]
> at
>
> org.apache.commons.dbcp.DelegatingConnection.prepareStatement(DelegatingConnection.java:281)[commons-dbcp-1.4.jar:1.4]
> at
>
> org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper.prepareStatement(PoolingDataSource.java:313)[commons-dbcp-1.4.jar:1.4]
> at
>
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRemoveMessage(DefaultJDBCAdapter.java:381)[activemq-jdbc-store-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.store.jdbc.JDBCMessageStore.removeMessage(JDBCMessageStore.java:260)[activemq-jdbc-store-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.store.memory.MemoryTransactionStore.removeMessage(MemoryTransactionStore.java:373)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.store.memory.MemoryTransactionStore$1.removeAsyncMessage(MemoryTransactionStore.java:170)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.region.Queue.acknowledge(Queue.java:923)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.region.Queue.removeMessage(Queue.java:1718)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.region.QueueSubscription.acknowledge(QueueSubscription.java:55)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:277)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:441)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:484)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:277)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:87)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:97)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:550)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.command.MessageAck.visit(MessageAck.java:245)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:130)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:107)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.network.DemandForwardingBridgeSupport$11.onCompletion(DemandForwardingBridgeSupport.java:1012)[activemq-broker-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.FutureResponse.set(FutureResponse.java:65)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:109)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)[activemq-client-5.11.1.jar:5.11.1]
> at
>
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)[activemq-client-5.11.1.jar:5.11.1]
> at java.lang.Thread.run(Thread.java:745)[:1.7.0_80]
> 2016-03-03 14:41:13,073 | WARN | Transport Connection to:
> vm://PRD_ACTIVEMQ_C1#0 failed: java.io.IOException: Failed to broker
> message: ID:*-36573-1456931506213-1:3:1:1:7874 in container:
> org.apache.commons.dbcp.SQLNestedException: Borrow prepareStatement from
> pool failed | org.apache.activemq.broker.TransportConnection.Transport |
> ActiveMQ Transport: tcp://10.102.44.181:61616@38805
> 2016-03-03 14:41:13,074 | INFO | PRD_ACTIVEMQ_C1 Shutting down |
> org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
> BrokerService[PRD_ACTIVEMQ_C1] Task-25434
> 2016-03-03 14:41:23,080 | INFO | Network Could not shutdown in a timely
> manner | org.apache.activemq.network.DemandForwardingBridgeSupport |
> ActiveMQ BrokerService[PRD_ACTIVEMQ_C1] Task-25434
> 2016-03-03 14:41:24,083 | INFO | PRD_ACTIVEMQ_C1 bridge to localhost
> stopped
> | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
> BrokerService[PRD_ACTIVEMQ_C1] Task-25434
>
> *It is very URGENT since we found this issue on our production environment!
> Please help !!!!!!*
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Failed-network-connector-can-not-be-re-established-tp4709054.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

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