svn commit: r583430 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java

[arnaudsimon]

Author: arnaudsimon
Date: Wed Oct 10 04:11:10 2007
New Revision: 583430

URL: http://svn.apache.org/viewvc?rev=583430&view=rev
Log:
Changed sendCancel to sedn a cancel and not a stop

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=583430&r1=583429&r2=583430&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
 Wed Oct 10 04:11:10 2007
@@ -172,7 +172,7 @@
      */
     public void sendCancel() throws JMSAMQException
     {
-        ((AMQSession_0_10) 
getSession()).getQpidSession().messageStop(getConsumerTag().toString());
+        ((AMQSession_0_10) 
getSession()).getQpidSession().messageCancel(getConsumerTag().toString());
         ((AMQSession_0_10) getSession()).getQpidSession().sync();
         // confirm cancel
         getSession().confirmConsumerCancelled(getConsumerTag());