You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by bu...@apache.org on 2013/07/23 22:21:42 UTC

svn commit: r870871 - in /websites/production/activemq/content: cache/main.pageCache slow-consumer-handling.html

Author: buildbot
Date: Tue Jul 23 20:21:41 2013
New Revision: 870871

Log:
Production update by buildbot for activemq

Modified:
    websites/production/activemq/content/cache/main.pageCache
    websites/production/activemq/content/slow-consumer-handling.html

Modified: websites/production/activemq/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.

Modified: websites/production/activemq/content/slow-consumer-handling.html
==============================================================================
--- websites/production/activemq/content/slow-consumer-handling.html (original)
+++ websites/production/activemq/content/slow-consumer-handling.html Tue Jul 23 20:21:41 2013
@@ -32,16 +32,6 @@
     </style>
     <![endif]-->
 
-          <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' /> 
-      <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' /> 
-      <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script> 
-              <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script> 
-              <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushXml.js' type='text/javascript'></script> 
-         
-      <script type="text/javascript"> 
-        SyntaxHighlighter.defaults['toolbar'] = false; 
-        SyntaxHighlighter.all(); 
-      </script> 
     
     <title>
     Apache ActiveMQ &#8482; -- Slow Consumer Handling
@@ -153,7 +143,66 @@
 
 <p>The following example shows an ActiveMQ broker configuration file. Notice that for topics in the <b>PRICES.&gt;</b> wildcard range the <b>pendingMessageLimitStrategy</b> property is set to only keep around 10 messages for each consumer above their prefetch buffer size.</p>
 
-<div class="error"><span class="error">Error formatting macro: snippet: java.lang.IndexOutOfBoundsException: Index: 20, Size: 20</span> </div>
+<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+&lt;beans 
+  xmlns="http://www.springframework.org/schema/beans" 
+  xmlns:amq="http://activemq.apache.org/schema/core"
+  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.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"&gt;
+
+  &lt;bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/&gt;
+
+  &lt;broker persistent="false" brokerName="${brokername}" xmlns="http://activemq.apache.org/schema/core"&gt;
+
+    &lt;!--  lets define the dispatch policy --&gt;
+    &lt;destinationPolicy&gt;
+      &lt;policyMap&gt;
+        &lt;policyEntries&gt;
+          &lt;policyEntry topic="FOO.&gt;"&gt;
+            &lt;dispatchPolicy&gt;
+              &lt;roundRobinDispatchPolicy /&gt;
+            &lt;/dispatchPolicy&gt;
+            &lt;subscriptionRecoveryPolicy&gt;
+              &lt;lastImageSubscriptionRecoveryPolicy /&gt;
+            &lt;/subscriptionRecoveryPolicy&gt;
+          &lt;/policyEntry&gt;
+
+          &lt;policyEntry topic="ORDERS.&gt;"&gt;
+            &lt;dispatchPolicy&gt;
+              &lt;strictOrderDispatchPolicy /&gt;
+            &lt;/dispatchPolicy&gt;
+            &lt;!--  1 minutes worth --&gt;
+            &lt;subscriptionRecoveryPolicy&gt;
+              &lt;timedSubscriptionRecoveryPolicy recoverDuration="60000" /&gt;
+            &lt;/subscriptionRecoveryPolicy&gt;
+          &lt;/policyEntry&gt;
+
+          &lt;policyEntry topic="PRICES.&gt;"&gt;
+
+            &lt;!-- lets force old messages to be discarded for slow consumers --&gt;
+            &lt;pendingMessageLimitStrategy&gt;
+              &lt;constantPendingMessageLimitStrategy limit="10"/&gt;
+            &lt;/pendingMessageLimitStrategy&gt;
+
+            &lt;!--  10 seconds worth --&gt;
+            &lt;subscriptionRecoveryPolicy&gt;
+              &lt;timedSubscriptionRecoveryPolicy recoverDuration="10000" /&gt;
+            &lt;/subscriptionRecoveryPolicy&gt;
+            
+          &lt;/policyEntry&gt;
+          &lt;policyEntry tempTopic="true" advisoryForConsumed="true" /&gt;
+
+          &lt;policyEntry tempQueue="true" advisoryForConsumed="true" /&gt;
+        &lt;/policyEntries&gt;
+      &lt;/policyMap&gt;
+    &lt;/destinationPolicy&gt;
+  &lt;/broker&gt;
+
+&lt;/beans&gt;
+]]></script>
+</div></div>
 
 <h2><a shape="rect" name="SlowConsumerHandling-Usagetips"></a>Usage tips</h2>