[hornetq-commits] JBoss hornetq SVN: r10563 - in trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue: push and 1 other directory.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-04-27 22:23:07 -0400 (Wed, 27 Apr 2011)
New Revision: 10563

Modified:
   trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/QueueConsumer.java
   trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/push/PushConsumer.java
Log:
Fixing ACK on Rest

Modified: trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/QueueConsumer.java
===================================================================
--- trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/QueueConsumer.java	2011-04-27 22:30:19 UTC (rev 10562)
+++ trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/QueueConsumer.java	2011-04-28 02:23:07 UTC (rev 10563)
@@ -198,7 +198,7 @@
    protected void createSession()
            throws HornetQException
    {
-      session = factory.createSession(true, true);
+      session = factory.createSession(true, true, 0);
       if (selector == null)
       {
          consumer = session.createConsumer(destination);

Modified: trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/push/PushConsumer.java
===================================================================
--- trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/push/PushConsumer.java	2011-04-27 22:30:19 UTC (rev 10562)
+++ trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue/push/PushConsumer.java	2011-04-28 02:23:07 UTC (rev 10563)
@@ -70,7 +70,7 @@
       strategy.setRegistration(registration);
       strategy.start();
 
-      session = factory.createSession(false, false);
+      session = factory.createSession(true, true, 0);
       if (registration.getSelector() != null)
       {
          consumer = session.createConsumer(destination, SelectorTranslator.convertToHornetQFilterString(registration.getSelector()));