diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-10-17 16:06:06 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-10-17 16:06:06 +0000 |
| commit | cbd4b306577e57075b47f8825e8fc46b3966ddf4 (patch) | |
| tree | 0457523c078c337580cbc07519faf8095fd6becf /qpid/java | |
| parent | e8b912389729d6af79ab99bd555afa28acf277bc (diff) | |
| download | qpid-python-cbd4b306577e57075b47f8825e8fc46b3966ddf4.tar.gz | |
s/setPrefecthLimits/setPrefetchLimits
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@705654 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java | 2 | ||||
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java | 6 |
2 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java index 07e7419426..d1fb852c06 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java @@ -486,7 +486,7 @@ public final class AMQSession_0_8 extends AMQSession<BasicMessageConsumer_0_8, B - 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>() diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java index 94096e412d..910d546034 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/FlowControlTest.java @@ -79,7 +79,7 @@ public class FlowControlTest extends QpidTestCase 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 @@ public class FlowControlTest extends QpidTestCase 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 @@ public class FlowControlTest extends QpidTestCase 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); |