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