summaryrefslogtreecommitdiff
path: root/dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs
diff options
context:
space:
mode:
Diffstat (limited to 'dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs')
-rw-r--r--dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs9
1 files changed, 5 insertions, 4 deletions
diff --git a/dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs b/dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs
index bb5758c18c..a52b4e2c50 100644
--- a/dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs
+++ b/dotnet/Qpid.Client.Tests/requestreply1/ServiceProvidingClient.cs
@@ -60,8 +60,9 @@ namespace Qpid.Client.Tests
_channel.DeclareQueue(_serviceName, false, false, false);
IMessageConsumer consumer = _channel.CreateConsumerBuilder(_serviceName)
- .withPrefetch(100)
- .withNoLocal(true)
+ .WithPrefetchLow(100)
+ .WithPrefetchHigh(500)
+ .WithNoLocal(true)
.Create();
consumer.OnMessage = new MessageReceivedDelegate(OnMessage);
}
@@ -100,8 +101,8 @@ namespace Qpid.Client.Tests
// Console.WriteLine("ReplyTo.RoutingKey = " + _replyToRoutingKey);
_destinationPublisher = _channel.CreatePublisherBuilder()
- .withExchangeName(_replyToExchangeName)
- .withRoutingKey(_replyToRoutingKey)
+ .WithExchangeName(_replyToExchangeName)
+ .WithRoutingKey(_replyToRoutingKey)
.Create();
_destinationPublisher.DisableMessageTimestamp = true;
_destinationPublisher.DeliveryMode = DeliveryMode.NonPersistent;