On Thu, May 1, 2008 at 2:16 PM, seven_ephors <[EMAIL PROTECTED]> wrote: > > I am using the TopicPublisher.java code in the 5.0.0\example\src directory, > with slight modifications. It seem to work pretty well, but when I have > large number of messages, it always stop working after certain number of > messages are published. For a BytesMessage with data size of 256X128, I can > only send up to 743 message. After that, the publisher can't send any more > message to the broker. In order to get it to work again, I need to ctrl-C > on the ActiveMQ DOS window, and restart the broker. Since I need to publish > topic continuously, I need to find solution to the problem. > > My questions are, 1, anyone have similar problem with a publisher? 2, What > am I doing wrong? 3, What solution is there?
Most typically this is an issue with the consumer side processing being much slower than the broker side, so the messages back up on the broker. One solution to such slow consumer situations is to use the consumer prefetch prefetch policy. See the following for more info: http://activemq.apache.org/what-is-the-prefetch-limit-for.html Please read through that and see if it describes your situation and if it does, give the prefetch policy a try. Bruce -- perl -e 'print unpack("u30","D0G)[EMAIL PROTECTED]&5R\"F)R=6-E+G-N>61E<D\!G;6%I;\"YC;VT*" );' Apache ActiveMQ - http://activemq.org/ Apache Camel - http://activemq.org/camel/ Apache ServiceMix - http://servicemix.org/ Apache Geronimo - http://geronimo.apache.org/ Blog: http://bruceblog.org/
