QPID-136 Ported Prefetch with PrefetchHigh and PrefetchLow

QPID-137 Ported AcknowledgeModes


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@481035 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 4 deletions

diff --git a/dotnet/Qpid.Client.Tests/requestreply1/ServiceRequestingClient.cs b/dotnet/Qpid.Client.Tests/requestreply1/ServiceRequestingClient.cs
index 582f022719..e437b670bf 100644
--- a/dotnet/Qpid.Client.Tests/requestreply1/ServiceRequestingClient.cs
+++ b/dotnet/Qpid.Client.Tests/requestreply1/ServiceRequestingClient.cs
@@ -53,7 +53,7 @@ namespace Qpid.Client.Tests
             try
             {
                 _publisher = _channel.CreatePublisherBuilder()
-                    .withRoutingKey(_commandQueueName)
+                    .WithRoutingKey(_commandQueueName)
                     .Create();
                 _publisher.DisableMessageTimestamp = true; // XXX: need a "with" for this in builder?
                 _publisher.DeliveryMode = DeliveryMode.NonPersistent;  // XXX: need a "with" for this in builder?
@@ -74,9 +74,10 @@ namespace Qpid.Client.Tests
             _channel.DeclareQueue(replyQueueName, false, true, true);
 
             IMessageConsumer messageConsumer = _channel.CreateConsumerBuilder(replyQueueName)
-                .withPrefetch(100)
-                .withNoLocal(true)
-                .withExclusive(true).Create();
+                .WithPrefetchLow(100)
+                .WithPrefetchHigh(200)
+                .WithNoLocal(true)
+                .WithExclusive(true).Create();
  
             _startTime = DateTime.Now.Ticks;