I have MySQL 5.1, I have InnoDB-Tables, but Slaves do not start up. The first process becomes master. The others block while trying to become master. They never become slaves. They try to execute
SELECT * FROM ACTIVEMQ_LOCK FOR UPDATE. This waits for the lock to be available and finally ends with a timeout. The next line in the log is: Failed to acquire lock. Sleeping for 1000 milli(s) before trying again... This keeps going forever. The server shows the line "Started Jetty Server" and accepts HTTP requests. The process that is to become slave never does either of this. 1) If I switch to Derby, the problem goes away. 2) In MySQL, I had some luck with changing the lock statement to SELECT * FROM ACTIVEMQ_LOCK LOCK IN SHARE MODE Some luck only because: 1) Failover does not work. Once I kill the master, no slave becomes master. 2) Even this is not reliable. I cannot reproduce it reliably, but sometime, the slave still does not start up. Here is my Spring app-context: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:tx="http://www.springframework.org/schema/tx"; xmlns:context="http://www.springframework.org/schema/context"; xmlns:p="http://www.springframework.org/schema/p"; xmlns:jms="http://www.springframework.org/schema/jms"; xmlns:amq="http://activemq.apache.org/schema/core"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.4.2.xsd";> <context:annotation-config /> <context:component-scan base-package="de.jeha" /> <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"> <property name="driverClass" value="com.mysql.jdbc.Driver" /> <property name="jdbcUrl" value="jdbc:mysql://${de.jeha.db.host}:3306/test?autoReconnectForPools=true" /> <property name="user" value="amqtest" /> <property name="password" value="amqtest" /> <property name="initialPoolSize" value="1" /> <property name="minPoolSize" value="1" /> <property name="maxPoolSize" value="3" /> <property name="preferredTestQuery" value="SELECT 1;" /> <property name="idleConnectionTestPeriod" value="300" /> </bean> <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean" p:dataSource-ref="dataSource" /> <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager" p:entityManagerFactory-ref="entityManagerFactory" /> <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver" /> <property name="url" value="jdbc:mysql://${de.jeha.db.host}:3306/test_activemq?relaxAutoCommit=true&profileSQL=true" /> <!-- &profileSQL=true --> <property name="username" value="amqtest" /> <property name="password" value="amqtest" /> <property name="poolPreparedStatements" value="true" /> </bean> <bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="org.apache.derby.jdbc.ClientDriver" /> <property name="url" value="jdbc:derby://localhost:1527/amqtest" /> <property name="username" value="default" /> <property name="password" value="default" /> <property name="poolPreparedStatements" value="true" /> </bean> <amq:broker id="broker" useJmx="true" brokerName="brokerName1"> <amq:managementContext> <amq:managementContext connectorPort="${de.jeha.jmxport}" jmxDomainName="org.apache.activemq" /> </amq:managementContext> <amq:persistenceAdapter> <amq:jdbcPersistenceAdapter dataSource="#mysql-ds" useDatabaseLock="true" createTablesOnStartup="true"> <!--<amq:jdbcPersistenceAdapter dataSource="#derby-ds" useDatabaseLock="true" createTablesOnStartup="true">--> <amq:statements> <amq:statements lockTableName="ACTIVEMQ_LOCK" lockCreateStatement="SELECT * FROM ACTIVEMQ_LOCK LOCK IN SHARE MODE" messageTableName="ACTIVEMQ_MSGS" durableSubAcksTableName="ACTIVEMQ_ACKS"/> </amq:statements> </amq:jdbcPersistenceAdapter> </amq:persistenceAdapter> <amq:plugins> <amq:statisticsBrokerPlugin /> </amq:plugins> <amq:transportConnectors> <!--<amq:transportConnector name="default" uri="tcp://10.121.123.26:61616" />--> <amq:transportConnector name="default" uri="tcp://10.121.123.26:${de.jeha.amq.host.port}" /> </amq:transportConnectors> </amq:broker> <amq:queue id="destination" physicalName="amq.test" /> <amq:connectionFactory id="jmsFactory" brokerURL="failover:(tcp://10.121.123.26:61616,tcp://10.121.123.26:62616)?initialReconnectDelay=100" /> <bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager" p:connectionFactory-ref="jmsFactory" /> <bean id="jmsConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory" p:targetConnectionFactory-ref="jmsFactory" /> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" p:connectionFactory-ref="jmsConnectionFactory" p:defaultDestination-ref="destination" /> <bean id="simpleJMSReceiver" class="de.jeha.spring_activemq_webapp.struts2.mdp.SimpleJMSReceiver" /> <bean id="jmsMessageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter"> <constructor-arg ref="simpleJMSReceiver" /> <property name="messageConverter"> <null /> </property> </bean> <jms:listener-container container-type="default" connection-factory="jmsFactory" acknowledge="auto"> <jms:listener destination="amq.test" ref="jmsMessageListener" /> </jms:listener-container> </beans> I start my test processes with different values for $de.jeha.amq.host.port. The values are those listed in the failover url: failover:(tcp://10.121.123.26:61616,tcp://10.121.123.26:62616) Thanks in advance for anything that could point me in the right direction. Albrecht -- View this message in context: http://activemq.2283324.n4.nabble.com/Master-Slave-Failover-with-JDBC-blocks-Tomcat-startup-tp3173318p3173318.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
