summaryrefslogtreecommitdiff
path: root/qpid/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs')
-rw-r--r--qpid/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs6
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs b/qpid/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs
index 6b6fca20b2..687f08eeef 100644
--- a/qpid/dotnet/Qpid.Client.Tests/MultiConsumer/ProducerMultiConsumer.cs
+++ b/qpid/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();