summaryrefslogtreecommitdiff
path: root/dotnet/Qpid.Client.Tests/MultiConsumer
diff options
context:
space:
mode:
Diffstat (limited to 'dotnet/Qpid.Client.Tests/MultiConsumer')
-rw-r--r--dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs6
1 files changed, 3 insertions, 3 deletions
diff --git a/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs b/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs
index 6b6fca20b2..687f08eeef 100644
--- a/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs
+++ b/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs
@@ -70,8 +70,8 @@ namespace Qpid.Client.Tests
{
base.Init();
_publisher = _channel.CreatePublisherBuilder()
- .withRoutingKey(_commandQueueName)
- .withExchangeName(ExchangeNameDefaults.TOPIC)
+ .WithRoutingKey(_commandQueueName)
+ .WithExchangeName(ExchangeNameDefaults.TOPIC)
.Create();
_publisher.DisableMessageTimestamp = true;
@@ -85,7 +85,7 @@ namespace Qpid.Client.Tests
_channel.Bind(queueName, ExchangeNameDefaults.TOPIC, _commandQueueName);
_consumers[i] = _channel.CreateConsumerBuilder(queueName)
- .withPrefetch(100).Create();
+ .WithPrefetchLow(100).Create();
_consumers[i].OnMessage = new MessageReceivedDelegate(OnMessage);
}
_connection.Start();