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

Author: clebert.suconic(a)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 ||