[hornetq-commits] JBoss hornetq SVN: r10563 - in trunk/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/queue: push and 1 other directory.
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()));