svn commit: r705654 - in /incubator/qpid/trunk/qpid/java: client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java

[aidan]

Author: aidan
Date: Fri Oct 17 09:06:06 2008
New Revision: 705654

URL: http://svn.apache.org/viewvc?rev=705654&view=rev
Log:
s/setPrefecthLimits/setPrefetchLimits

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
    
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java?rev=705654&r1=705653&r2=705654&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
 Fri Oct 17 09:06:06 2008
@@ -486,7 +486,7 @@
 
 
 
-    public void setPrefecthLimits(final int messagePrefetch, final long 
sizePrefetch) throws AMQException
+    public void setPrefetchLimits(final int messagePrefetch, final long 
sizePrefetch) throws AMQException
     {
         new FailoverRetrySupport<Object, AMQException>(
                 new FailoverProtectedOperation<Object, AMQException>()

Modified: 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java?rev=705654&r1=705653&r2=705654&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java
 Fri Oct 17 09:06:06 2008
@@ -79,7 +79,7 @@
 
         Connection consumerConnection = getConnection();
         Session consumerSession = consumerConnection.createSession(false, 
Session.CLIENT_ACKNOWLEDGE);
-        ((AMQSession_0_8) consumerSession).setPrefecthLimits(0, 256);
+        ((AMQSession_0_8) consumerSession).setPrefetchLimits(0, 256);
         MessageConsumer recv = consumerSession.createConsumer(_queue);
         consumerConnection.start();
 
@@ -152,7 +152,7 @@
 
         Connection consumerConnection = getConnection();
         Session consumerSession1 = consumerConnection.createSession(false, 
Session.CLIENT_ACKNOWLEDGE);
-        ((AMQSession_0_8) consumerSession1).setPrefecthLimits(0, 256);
+        ((AMQSession_0_8) consumerSession1).setPrefetchLimits(0, 256);
         MessageConsumer recv1 = consumerSession1.createConsumer(_queue);
 
         consumerConnection.start();
@@ -165,7 +165,7 @@
         assertNull("Second message incorrectly delivered", r2);
 
         Session consumerSession2 = consumerConnection.createSession(false, 
Session.CLIENT_ACKNOWLEDGE);
-        ((AMQSession_0_8) consumerSession2).setPrefecthLimits(0, 256);
+        ((AMQSession_0_8) consumerSession2).setPrefetchLimits(0, 256);
         MessageConsumer recv2 = consumerSession2.createConsumer(_queue);
 
         r2 = recv2.receive(100000L);//RECEIVE_TIMEOUT);