[jboss-cvs] JBoss Messaging SVN: r3610 - trunk/src/main/org/jboss/jms/client/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-01-21 21:49:28 -0500 (Mon, 21 Jan 2008)
New Revision: 3610

Modified:
   trunk/src/main/org/jboss/jms/client/impl/ClientConsumerImpl.java
Log:
Fixing ClientConsumer and MessageConsumerTest

Modified: trunk/src/main/org/jboss/jms/client/impl/ClientConsumerImpl.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/impl/ClientConsumerImpl.java	2008-01-22 01:32:51 UTC (rev 3609)
+++ trunk/src/main/org/jboss/jms/client/impl/ClientConsumerImpl.java	2008-01-22 02:49:28 UTC (rev 3610)
@@ -93,7 +93,6 @@
    private PriorityLinkedList<JBossMessage> buffer = new PriorityLinkedListImpl<JBossMessage>(10);
    private volatile Thread receiverThread;
    private MessageListener listener;
-   private int ackMode;
    private boolean closed;
    private Object mainLock = new Object();
    private QueuedExecutor sessionExecutor;
@@ -1060,7 +1059,7 @@
             try
             {
                callOnMessage(session, theListener, id,
-                             false, msg, ackMode, maxDeliveries, null, shouldAck);
+                             false, msg, session.getAcknowledgeMode(), maxDeliveries, null, shouldAck);
                
                if (trace) { log.trace("Called callonMessage"); }
             }