You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/01/28 20:04:40 UTC
svn commit: r738585 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
Author: cwiklik
Date: Wed Jan 28 19:04:39 2009
New Revision: 738585
URL: http://svn.apache.org/viewvc?rev=738585&view=rev
Log:
UIMA-1272 Added prefetch=5 to Client Temp Queue Connection
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java?rev=738585&r1=738584&r2=738585&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngine_impl.java Wed Jan 28 19:04:39 2009
@@ -34,7 +34,9 @@
import javax.jms.TextMessage;
import javax.management.ObjectName;
+import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.ActiveMQPrefetchPolicy;
import org.apache.activemq.RedeliveryPolicy;
import org.apache.activemq.command.ActiveMQBytesMessage;
import org.apache.activemq.command.ActiveMQDestination;
@@ -278,26 +280,22 @@
{
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(aBrokerURI);
connection = factory.createConnection();
+ // This only effects Consumer
+ addPrefetch((ActiveMQConnection)connection);
connection.start();
}
return connection;
}
+ private void addPrefetch(ActiveMQConnection aConnection ) {
+ ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy();
+ prefetchPolicy.setQueuePrefetch(5);
+ ((ActiveMQConnection)aConnection).setPrefetchPolicy(prefetchPolicy);
+ }
private void validateConnection(String aBrokerURI) throws Exception
{
- if (connection == null)
- {
- ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(aBrokerURI);
- System.out.println(">>>>>>>>>>>>> BaseUIMAAsynchronousEngine_impl.validateConnection() Adding policy");
- RedeliveryPolicy policy = new RedeliveryPolicy();
- policy.setMaximumRedeliveries(1);
- policy.setBackOffMultiplier((short) 1);
- policy.setInitialRedeliveryDelay(10);
- policy.setUseExponentialBackOff(false);
- factory.setRedeliveryPolicy(policy);
-
- connection = factory.createConnection();
- connection.start();
+ if (connection == null) {
+ connection = getConnection(aBrokerURI);
}
}
protected Session getSession(String aBrokerURI) throws Exception