Skip to content

Commit 1f3a863

Browse files
committed
Disable obsolete QueueingBasicConsumer warning
1 parent 06ecb7e commit 1f3a863

File tree

2 files changed

+12
-6
lines changed

2 files changed

+12
-6
lines changed

src/NServiceBus.RabbitMQ.Tests/When_sending_a_message_over_rabbitmq.cs

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public void Should_set_the_content_type()
2929

3030
}
3131

32-
32+
3333
[Test]
3434
public void Should_default_the_content_type_to_octet_stream_when_no_content_type_is_specified()
3535
{
@@ -38,7 +38,7 @@ public void Should_default_the_content_type_to_octet_stream_when_no_content_type
3838

3939
}
4040

41-
41+
4242

4343
[Test]
4444
public void Should_set_the_message_type_based_on_the_encoded_message_types_header()
@@ -66,7 +66,7 @@ public void Should_set_the_reply_to_address()
6666
{
6767
var address = Address.Parse("myAddress");
6868

69-
Verify(new TransportMessageBuilder().ReplyToAddress(address),
69+
Verify(new TransportMessageBuilder().ReplyToAddress(address),
7070
(t, r) =>
7171
{
7272
Assert.AreEqual(address, t.ReplyToAddress);
@@ -82,7 +82,7 @@ public void Should_not_populate_the_callback_header()
8282
(t, r) => Assert.IsFalse(t.Headers.ContainsKey(RabbitMqMessageSender.CallbackHeaderKey)));
8383

8484
}
85-
85+
8686
[Test]
8787
public void Should_set_correlation_id_if_present()
8888
{
@@ -155,7 +155,7 @@ void SendMessage(TransportMessage message)
155155

156156
if (message.MessageIntent == MessageIntentEnum.Reply)
157157
{
158-
158+
159159
}
160160
sender.Send(message, options);
161161
}
@@ -169,7 +169,9 @@ BasicDeliverEventArgs Consume(string id, string queueToReceiveOn)
169169

170170
using (var channel = connectionManager.GetConsumeConnection().CreateModel())
171171
{
172+
#pragma warning disable CS0618
172173
var consumer = new QueueingBasicConsumer(channel);
174+
#pragma warning restore CS0618
173175

174176
channel.BasicConsume(queueToReceiveOn, false, consumer);
175177

@@ -193,7 +195,7 @@ BasicDeliverEventArgs Consume(string id, string queueToReceiveOn)
193195

194196
class MyMessage
195197
{
196-
198+
197199
}
198200

199201
}

src/NServiceBus.RabbitMQ/RabbitMqDequeueStrategy.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,9 @@ void ConsumeMessages(object state)
154154
{
155155
channel.BasicQos(0, actualPrefetchCount, false);
156156

157+
#pragma warning disable CS0618
157158
var consumer = new QueueingBasicConsumer(channel);
159+
#pragma warning restore CS0618
158160

159161
channel.BasicConsume(parameters.Queue, false, receiveOptions.ConsumerTag, consumer);
160162

@@ -253,6 +255,7 @@ void ConsumeMessages(object state)
253255
}
254256
}
255257

258+
#pragma warning disable CS0618
256259
static BasicDeliverEventArgs DequeueMessage(QueueingBasicConsumer consumer, int dequeueTimeout)
257260
{
258261
BasicDeliverEventArgs rawMessage;
@@ -266,6 +269,7 @@ static BasicDeliverEventArgs DequeueMessage(QueueingBasicConsumer consumer, int
266269

267270
return rawMessage;
268271
}
272+
#pragma warning disable CS0618
269273

270274
void Purge()
271275
{

0 commit comments

Comments
 (0)