You using AMQ 5.0.0 ?? On Dec 14, 2007 6:23 AM, Dave Song <[EMAIL PROTECTED]> wrote: > > Hi,there > > I have a question when using JDBC Master/Slave. Some of the messages that > have sent to queue are not consumed by messageListener > > > I used ActiveMQ with spring. It worked perfect with one broker. the beans > configuration is like: > > > <bean id="twoBrokersTestJmsTemplate" > class="org.springframework.jms.core.JmsTemplate"> > <property name="defaultDestinationName" > value="ActiveMQ.In.twoBrokersTest" /> > <property name="connectionFactory"> > <ref bean="twoBrokersTestJmsFactory" /> > </property> > </bean> > > <bean id="twoBrokersTestJmsFactory" > class="org.apache.activemq.pool.PooledConnectionFactory"> > <property name="connectionFactory"> > <bean > > class="org.apache.activemq.ActiveMQConnectionFactory"> > <property name="brokerURL" > value="tcp://192.168.1.102:61616"/> > </bean> > </property> > </bean> > > <bean name="twoBrokersTestQueueListener" > class="activemqTest.twoBrokers.TwoBrokersTestListener"> > </bean> > > <bean id="twoBrokersTestQueueListenerContainer" > > class="org.springframework.jms.listener.DefaultMessageListenerContainer"> > <property name="concurrentConsumers" value="5" /> > <property name="connectionFactory" > ref="twoBrokersTestJmsFactory" /> > <property name="destinationName" > value="ActiveMQ.In.twoBrokersTest" /> > <property name="messageListener" > ref="twoBrokersTestQueueListener" /> > <property name="sessionAcknowledgeModeName" > value="CLIENT_ACKNOWLEDGE" /> > <property name="sessionTransacted" value="true" /> > </bean> > > > To made it work more reliable, i tried to use JDBC Master/Slave cluster. I > changed the brokerURL to: > > > failover:(tcp://192.168.1.102:61616,tcp://192.168.1.236:61616) > > And start two brokers in different PC. I configurate both of the > activemq.xml to use the jdbcPersistenceAdapter, like below: > > <persistenceAdapter> > <jdbcPersistenceAdapter dataSource="#mssql-ds" > useDatabaseLock="false"/> > </persistenceAdapter> > > The DB I used is SQLServer 2000. So I have to set useDatabaseLock to false > or else there will be an exception. > > > Then I sent some messages to queue with an interval. the problem is some of > the messages would not be consumed by the > messageListenr(twoBrokersTestQueueListener) if the interval is more than 30 > seconds. That is to say, it work fine if i sent the messages every 20 (or > any interval <= 29) seconds. > > > The only related constant I konw whose default value is set to 30 seconds is > "MaxInactivityDuration". I have tried to configurate > "wireFormat.maxInactivityDuration=0" in both client and broker to disable > it. However, I didn't work. > > It is very strange that "interval" makes the listeners not working as > expected. > > Any help/suggestions would be appreciated > > Thank you in advance, > > Dave > -- > View this message in context: > http://www.nabble.com/Messages-are-blocked-in-queue-when-using-JDBC-Master-Slave-tp14334149s2354p14334149.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > >
-- Regards, Hiram Blog: http://hiramchirino.com Open Source SOA http://open.iona.com
