Return-Path: 
 <dev-return-17716-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 84583 invoked from network); 18 Nov 2009 15:05:16 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3)
  by minotaur.apache.org with SMTP; 18 Nov 2009 15:05:16 -0000
Received: (qmail 5739 invoked by uid 500); 18 Nov 2009 15:05:15 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 5711 invoked by uid 500); 18 Nov 2009 15:05:15 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 5701 invoked by uid 99); 18 Nov 2009 15:05:15 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Nov 2009 15:05:15 +0000
X-ASF-Spam-Status: No, hits=-10.5 required=5.0
	tests=AWL,BAYES_00,RCVD_IN_DNSWL_HI
X-Spam-Check-By: apache.org
Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Nov 2009 15:05:13 +0000
Received: from brutus (localhost [127.0.0.1])
	by brutus.apache.org (Postfix) with ESMTP id DEBBB234C1EF
	for <dev@activemq.apache.org>; Wed, 18 Nov 2009 07:04:52 -0800 (PST)
Message-ID: <1246175218.1258556692909.JavaMail.jira@brutus>
Date: Wed, 18 Nov 2009 07:04:52 -0800 (PST)
From: "Mark Gellings (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Commented: (AMQ-2498) Broker goes down when database is
 restarted or goes down
In-Reply-To: <1852942644.1258409752759.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c


    [ https://issues.apache.org/activemq/browse/AMQ-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=55549#action_55549 ] 

Mark Gellings commented on AMQ-2498:
------------------------------------

I have handled this problem using a connection pooler.  Master goes down, slave attempts to connect to database and retries however many times configured...  New slave then needs to be started up manually (or automatically through some automation).


  <bean id="mssql-ds" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
    <property name="driverClass" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
    <property name="jdbcUrl" value="jdbc:sqlserver://CAGR.qg.com:1433;databaseName=AtvMMS"/>
    <property name="user" value="user"/>
    <property name="password" value="password"/>
    <property name="acquireRetryAttempts" value="100"/>
    <property name="testConnectionOnCheckout" value="true"/>
    <property name="testConnectionOnCheckin" value="true"/>
    <property name="automaticTestTable" value="ACTIVEMQ_CONN_TEST"/>
    <property name="acquireRetryDelay" value="5000"/>
    <property name="preferredTestQuery" value="SELECT 1"/>
  </bean>

> Broker goes down when database is restarted or goes down
> --------------------------------------------------------
>
>                 Key: AMQ-2498
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2498
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.3.0
>            Reporter: Partha
>            Priority: Critical
>         Attachments: server.log
>
>
> When I database is idle for too long or I manually restart database, broker is shutting down. Does it not automatically try to reconnect? Am I missing anything?
> I am setting validationQuery and testOnBorrow to true in broker-config.xml datasource bean.
> Do I need to do anything else to tell broker for keep trying for database connection?
> error
> =========================
> Failed to checkpoint a message store: java.util.concurrent.ExecutionException: java.io.IOException: The TCP/IP connection to the host  has failed. java.net.ConnectException: Connection refused: connect
> java.util.concurrent.ExecutionException: java.io.IOException: The TCP/IP connection to the host  has failed. java.net.ConnectException: Connection refused: connect
>  at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
>  at java.util.concurrent.FutureTask.get(FutureTask.java:83)
>  at org.apache.activemq.store.journal.JournalPersistenceAdapter.doCheckpoint(JournalPersistenceAdapter.java:421)
>  at org.apache.activemq.store.journal.JournalPersistenceAdapter$1.iterate(JournalPersistenceAdapter.java:124)
>  at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
>  at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
>  at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
>  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
>  at java.lang.Thread.run(Thread.java:619)
> Caused by: java.io.IOException: The TCP/IP connection to the host  has failed. java.net.ConnectException: Connection refused: connect
>  at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:45)
>  at org.apache.activemq.store.jdbc.TransactionContext.getConnection(TransactionContext.java:61)
>  at org.apache.activemq.store.jdbc.TransactionContext.begin(TransactionContext.java:151)
>  at org.apache.activemq.store.jdbc.JDBCPersistenceAdapter.beginTransaction(JDBCPersistenceAdapter.java:406)
>  at org.apache.activemq.store.journal.JournalPersistenceAdapter.beginTransaction(JournalPersistenceAdapter.java:216)
>  at org.apache.activemq.util.TransactionTemplate.run(TransactionTemplate.java:41)
>  at org.apache.activemq.store.journal.JournalMessageStore.checkpoint(JournalMessageStore.java:258)
>  at org.apache.activemq.store.journal.JournalTopicMessageStore.checkpoint(JournalTopicMessageStore.java:171)
>  at org.apache.activemq.store.journal.JournalPersistenceAdapter$5.call(JournalPersistenceAdapter.java:408)
>  at org.apache.activemq.store.journal.JournalPersistenceAdapter$5.call(JournalPersistenceAdapter.java:407)
>  at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
>  at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>  ... 3 more
> Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: The TCP/IP connection to the host  has failed. java.net.ConnectException: Connection refused: connect
>  at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(Unknown Source)
>  at com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(Unknown Source)
>  at com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(Unknown Source)
>  at org.apache.commons.dbcp.DriverConnectionFactory.createConnection(DriverConnectionFactory.java:38)
>  at org.apache.commons.dbcp.PoolableConnectionFactory.makeObject(PoolableConnectionFactory.java:294)
>  at org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:974)
>  at org.apache.commons.dbcp.PoolingDataSource.getConnection(PoolingDataSource.java:96)
>  at org.apache.commons.dbcp.BasicDataSource.getConnection(BasicDataSource.java:880)
>  at org.apache.activemq.store.jdbc.TransactionContext.getConnection(TransactionContext.java:54)
>  ... 13 more
> 2009-11-12 14:30:12,705 INFO  [STDOUT] 2009-11-12 14:30:12,705 [Q Cleanup Timer] INFO  BrokerService                  - ActiveMQ JMS Message Broker (ess.broker1, ID:VR1Server-8183-1258064801205-0:0) stopped
> ============
> Thanks,
> PG

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.