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
||