[jboss-cvs] JBoss Messaging SVN: r3610 - trunk/src/main/org/jboss/jms/client/impl.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Mon Jan 21 21:49:28 EST 2008
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"); }
}
More information about the jboss-cvs-commits
mailing list