ActiveMQ - SlowConsumer pocily replacement in HORNETQ

[rzvikas]

hi

we are currently on ActiveMQ where we have pocily defined to kick out slowconsumer so that there is no problem in sending messages to other subscriber or consumers who are processing the delivered messages fast.

I am looking for the something similar configuration in HORNETQ messaging system, Any suggestion ?

Here is my activemq.xml snippet :

<destinationPolicy>

   <policyMap>

    <policyEntries>

     <policyEntry queue=">" memoryLimit="5mb" />

     <policyEntry topic=">" memoryLimit="400 mb" producerFlowControl="true">

      <dispatchPolicy>

       <strictOrderDispatchPolicy />

      </dispatchPolicy>

     <slowConsumerStrategy>

          <abortSlowConsumerStrategy checkPeriod="1000" maxSlowDuration="15000" abortConnection="true"/>

      </slowConsumerStrategy>     

      <subscriptionRecoveryPolicy>

       <lastImageSubscriptionRecoveryPolicy />

      </subscriptionRecoveryPolicy>

     </policyEntry>

    </policyEntries>

   </policyMap>

  </destinationPolicy>

[ataylor]

we dont kick off consumers but you can set the client side buffer to avoid starvation, see http://docs.jboss.org/hornetq/2.3.0.Final/docs/user-manual/html_single/index.html#flow-control.consumer.window