cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject svn commit: r822030 - in /cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms: JMSConfiguration.java JMSOldConfigHolder.java
Date Mon, 05 Oct 2009 21:37:49 GMT
Author: dkulp
Date: Mon Oct  5 21:37:48 2009
New Revision: 822030

URL: http://svn.apache.org/viewvc?rev=822030&view=rev
Log:
Remove unused property and map the old session pool stuff in correctly

Modified:
    cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfiguration.java
    cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSOldConfigHolder.java

Modified: cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfiguration.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfiguration.java?rev=822030&r1=822029&r2=822030&view=diff
==============================================================================
--- cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfiguration.java
(original)
+++ cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConfiguration.java
Mon Oct  5 21:37:48 2009
@@ -68,7 +68,6 @@
     
     private int concurrentConsumers = 1;
     private int maxConcurrentConsumers = 1;
-    private int maxConcurrentTasks = 10;
     private int maxSuspendedContinuations = DEFAULT_VALUE;
     private int reconnectPercentOfMax = 70;
 
@@ -377,14 +376,6 @@
     public boolean isSetUseConduitIdSelector() {
         return useConduitIdSelector != null;
     }
-    
-    public int getMaxConcurrentTasks() {
-        return maxConcurrentTasks;
-    }
-
-    public void setMaxConcurrentTasks(int maxConcurrentTasks) {
-        this.maxConcurrentTasks = maxConcurrentTasks;
-    }
 
     public void setJndiTemplate(JndiTemplate jndiTemplate) {
         this.jndiTemplate = jndiTemplate;

Modified: cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSOldConfigHolder.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSOldConfigHolder.java?rev=822030&r1=822029&r2=822030&view=diff
==============================================================================
--- cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSOldConfigHolder.java
(original)
+++ cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSOldConfigHolder.java
Mon Oct  5 21:37:48 2009
@@ -143,7 +143,10 @@
             jmsConfig.setDurableSubscriptionName(serverBehavior.getDurableSubscriberName());
             jmsConfig.setDurableSubscriptionClientId(serverConfig.getDurableSubscriptionClientId());
             if (sessionPool.isSetHighWaterMark()) {
-                jmsConfig.setMaxConcurrentTasks(sessionPool.getHighWaterMark());
+                jmsConfig.setMaxConcurrentConsumers(sessionPool.getHighWaterMark());
+            }
+            if (sessionPool.isSetLowWaterMark()) {
+                jmsConfig.setConcurrentConsumers(sessionPool.getLowWaterMark());
             }
             long timeToLive = isConduit ? clientConfig.getMessageTimeToLive() : serverConfig
                 .getMessageTimeToLive();
@@ -351,7 +354,10 @@
             jmsConfig.setDurableSubscriptionName(serverBehavior.getDurableSubscriberName());
             jmsConfig.setDurableSubscriptionClientId(serverConfig.getDurableSubscriptionClientId());
             if (sessionPool.isSetHighWaterMark()) {
-                jmsConfig.setMaxConcurrentTasks(sessionPool.getHighWaterMark());
+                jmsConfig.setMaxConcurrentConsumers(sessionPool.getHighWaterMark());
+            }
+            if (sessionPool.isSetLowWaterMark()) {
+                jmsConfig.setConcurrentConsumers(sessionPool.getLowWaterMark());
             }
             if (endpoint.isSetTimeToLive()) {
                 long timeToLive = endpoint.getTimeToLive();



Mime
View raw message