svn commit: r822030 - in /cxf/trunk/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms: JMSConfiguration.java JMSOldConfigHolder.java

[dkulp]

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();