[hornetq-commits] JBoss hornetq SVN: r8900 - trunk/src/main/org/hornetq/ra/inflow.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-02-25 19:54:26 -0500 (Thu, 25 Feb 2010)
New Revision: 8900

Modified:
   trunk/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java
   trunk/src/main/org/hornetq/ra/inflow/HornetQMessageHandler.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-312 and adding a few backwards compatilibity properites on the resource adapter

Modified: trunk/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java
===================================================================
--- trunk/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java	2010-02-25 14:47:40 UTC (rev 8899)
+++ trunk/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java	2010-02-26 00:54:26 UTC (rev 8900)
@@ -718,22 +718,22 @@
    // here for backwards compatibilty
    public void setUseDLQ(final boolean b)
    {
-
    }
 
    public void setDLQJNDIName(final String name)
    {
-
    }
+   
+   public void setDLQHandler(final String handler)
+   {
+   }
 
    public void setDLQMaxResent(final int maxResent)
    {
-
    }
 
    public void setProviderAdapterJNDI(final String jndi)
    {
-
    }
 
    /**
@@ -751,4 +751,9 @@
    }
    
    
+   public void setReconnectInterval(long interval)
+   {
+   }
+   
+   
 }

Modified: trunk/src/main/org/hornetq/ra/inflow/HornetQMessageHandler.java
===================================================================
--- trunk/src/main/org/hornetq/ra/inflow/HornetQMessageHandler.java	2010-02-25 14:47:40 UTC (rev 8899)
+++ trunk/src/main/org/hornetq/ra/inflow/HornetQMessageHandler.java	2010-02-26 00:54:26 UTC (rev 8900)
@@ -107,12 +107,6 @@
          }
          else
          {
-            // Already exists
-            if (subResponse.getConsumerCount() > 0)
-            {
-               throw new javax.jms.IllegalStateException("Cannot create a subscriber on the durable subscription since it already has subscriber(s)");
-            }
-
             SimpleString oldFilterString = subResponse.getFilterString();
 
             boolean selectorChanged = selector == null && oldFilterString != null ||