You need to deal with that in your consumer. Delay consumption or connect to the broker and get only certain amount of messages at the time.
Regards -- Dejan Bosanac - http://twitter.com/dejanb ----------------- The experts in open source integration and messaging - http://fusesource.com ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Sun, Jan 15, 2012 at 10:54 AM, jeesim2 <[email protected]> wrote: > I'm sorry, My english is not good : ) > > > I have some problem in my system that is.. > between AM01 ~ AM02, there are too many user request to some URL. > so, significant "mysql insert statement(sql1)" processed, and mysql table > locked, and web service get out of order. > ( 500,000 insert sql1 queries in a hour ) > > So, I hope sql1 queries processed asynchronously, for example, 500,000 sql1 > queries processed during 3 hours. > > and I thought activeMQ+SpringJMS could be a solution. > > But, If [activeMQ+SpringJMS] does not support some delayed consummtion > mechanism, it can not be a solution. > > > AS-IS > [Webservice] --> [500,000 Insert queries in an hour ] --> [MYSQL] > > WANNA-BE > [Webservice] -->(JMS)-->[ActiveMQ] ---> [500,000 insert queries scattered > to > 3 hours]---> [Cunsumer] -->[MYSQL] > > > PURPOSE > - scatter the pick time's mysql insert statement widely. > > > Is there any way that solve my problem? > something like, 'consum a queue per a second' , or give interval between > queue consumtion. > > each insert queries data are different, > so http://activemq.apache.org/delay-and-schedule-message-delivery.html can > not help me. > > > I wish you understand me : ) > > > thankyou. > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/How-to-make-queues-not-to-be-comsumed-until-queue-size-exceed-some-value-tp4296516p4296516.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >
