Further to this I'd like to add that the broker shows that all 20000
messages have been enqueued and dequeued.  So the broker queue has no
messages remaining on it.

On Thu, Apr 17, 2008 at 2:24 PM, Dhruba Bandopadhyay <[EMAIL PROTECTED]> wrote:
> Hi,
>
>  Using spring 2.5.3 mdps, tomcat 6.0.16 and activemq 5.1.0-rc3 with 1
>  producer, 3 brokers and 1 consumer running 5 threads with almost
>  default broker configuration.
>
>  Producer and consumer connecting via the following url.
>
>  
> failover://(tcp://10.10.32.140:61616,tcp://10.10.32.142:61616,tcp://10.10.32.179:61616)?initialReconnectDelay=100&randomize=false
>
>  All brokers using following config.
>
>  <beans xmlns="http://www.springframework.org/schema/beans";
>  xmlns:amq="http://activemq.org/config/1.0";
>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
>     xsi:schemaLocation="http://www.springframework.org/schema/beans
>  http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>   http://activemq.org/config/1.0
>  http://activemq.apache.org/schema/activemq-core.xsd
>   http://activemq.apache.org/camel/schema/spring
>  http://activemq.apache.org/camel/schema/spring/camel-spring.xsd";>
>
>     <bean 
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"
>  />
>
>     <broker xmlns="http://activemq.org/config/1.0";
>  brokerName="broker3" dataDirectory="${activemq.base}/data">
>         <transportConnectors>
>             <transportConnector name="openwire" uri="tcp://localhost:61616" />
>         </transportConnectors>
>     </broker>
>
>     <jetty xmlns="http://mortbay.com/schemas/jetty/1.0";>
>         <connectors>
>             <nioConnector port="8161" />
>         </connectors>
>         <handlers>
>             <webAppContext contextPath="/admin"
>  resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />
>             <webAppContext contextPath="/demo"
>  resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />
>             <webAppContext contextPath="/fileserver"
>  resourceBase="${activemq.base}/webapps/fileserver"
>  logUrlOnStart="true" />
>         </handlers>
>     </jetty>
>
>  </beans>
>
>  Due to the client connection url the single consumer only uses the
>  first broker.  Note all multicast options are disabled to prevent
>  messages going from one broker to another.
>
>  When I send 20,000 messages frequently roughly 1000 or so go missing.
>
>  Is this correct behaviour given my setup?  What are the usual causes
>  of messages going missing?  I don't see any exceptions or failures
>  anywhere.  The consumer stats show that the consumer has only
>  processed roughly 19000 messages so it is definitely not the case that
>  it is has processed them but failed to do so correctly.
>
>  Any help, advice or link to appropriate documentation would be much
>  appreciated as for me this is a serious problem.
>
>  Many thanks.
>

Reply via email to