Return-Path: 
 <users-return-28880-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
X-Original-To: apmail-activemq-users-archive@www.apache.org
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id B3F2B785E
	for <apmail-activemq-users-archive@www.apache.org>;
 Tue, 20 Sep 2011 18:01:24 +0000 (UTC)
Received: (qmail 49869 invoked by uid 500); 20 Sep 2011 18:01:24 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 49842 invoked by uid 500); 20 Sep 2011 18:01:24 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 49831 invoked by uid 99); 20 Sep 2011 18:01:24 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Sep 2011 18:01:24 +0000
X-ASF-Spam-Status: No, hits=2.0 required=5.0
	tests=SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 20 Sep 2011 18:01:18 +0000
Received: from joe.nabble.com ([192.168.236.139])
	by sam.nabble.com with esmtp (Exim 4.72)
	(envelope-from <klaus.unger@iq-consultancy.net>)
	id 1R64cn-0004C6-95
	for users@activemq.apache.org; Tue, 20 Sep 2011 11:00:53 -0700
Date: Tue, 20 Sep 2011 11:00:53 -0700 (PDT)
From: "Klaus.Unger" <klaus.unger@iq-consultancy.net>
To: users@activemq.apache.org
Message-ID: <1316541653236-3827666.post@n4.nabble.com>
Subject: Shared Database Master/Slave config throws JMSException when
 aborting Master
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hello,

I have a scenario (Spring, ActiveMQ, PostgreSQL) where we want to configure
our messaging to provide automatic failover and no additional interaction on
bringing a failed master back online (like in pure-shared-nothing
master/slave).

as mentioned in ActiveMQ in action I just started multiple brokers using the
same configuration - besides the SQL Warnings that the tables in the
PostgreSQL DB already exists, everythings works fine.

I start an integrationtest, which sends a couple of thousand simple messages
to the broker(s). 

when I kill the master in charge, the failover takes perfectly place: 

14184   WARN   transport.failover.FailoverTransport Transport
(localhost/127.0.0.1:61616) failed to tcp://localhost:61616 , attempting to
automatically reconnect due to: java.io.EOFException
14552   INFO   transport.failover.FailoverTransport Successfully reconnected
to tcp://localhost:61616

so far so good, but immediately after I receive the following:

14607   WARN   jms.connection.CachingConnectionFactory Encountered a
JMSException - resetting the underlying JMS Connection
javax.jms.JMSException: The subscription does not exist:
ID:iQ-MacBook-Pro-15.local-58766-1316540825439-0:1:1:37
...

Caused by: java.lang.IllegalArgumentException: The subscription does not
exist: ID:iQ-MacBook-Pro-15.local-58766-1316540825439-0:1:1:37
	at
org.apache.activemq.broker.region.AbstractRegion.messagePull(AbstractRegion.java:389)
...

my re-used broker config looks like this:

  <broker useJmx="false" brokerName="jdbcBroker"
xmlns="http://activemq.apache.org/schema/core">
    <persistenceAdapter>
       <jdbcPersistenceAdapter dataDirectory="${activemq.base}/data"
dataSource="#postgres-ds"/>
    </persistenceAdapter>

    <transportConnectors>
       <transportConnector name="default" uri="tcp://0.0.0.0:61617"/>
    </transportConnectors>
  </broker>
 
    <bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource">
        <property name="serverName" value="localhost"/>
        <property name="databaseName" value="activemq"/>
        <property name="portNumber" value="0"/>
        <property name="user" value="activemq"/>
        <property name="password" value="activemq"/>
        <property name="dataSourceName" value="postgres"/>
        <property name="initialConnections" value="1"/>
        <property name="maxConnections" value="10"/>
    </bean>

my spring config looks like:

  <bean id="amqConnectionFactory"
class="org.apache.activemq.spring.ActiveMQConnectionFactory"
    p:brokerURL="${jms.brokerUrl}"
    p:clientIDPrefix="${jms.clientIDPrefix}" />

  <bean id="jmsConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory"
	p:targetConnectionFactory-ref="amqConnectionFactory" 
    p:sessionCacheSize="${jms.sessionCacheSize}" 
    p:reconnectOnException="true"
    p:exceptionListener-ref="jmsExceptionListener" />


I've searched almost the whole day now, but didn't come to any conclusion!
Any help, hints, ... very appreciated!

thx
K:)



--
View this message in context: http://activemq.2283324.n4.nabble.com/Shared-Database-Master-Slave-config-throws-JMSException-when-aborting-Master-tp3827666p3827666.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.