Skip to content

Commit eacaa18

Browse files
committed
Fix #98
1 parent d878ea4 commit eacaa18

File tree

4 files changed

+3
-45
lines changed

4 files changed

+3
-45
lines changed

projects/client/RabbitMQ.Client/src/client/api/IModel.cs

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ public interface IModel : IDisposable
139139
///
140140
/// Examples of cases where this event will be signalled
141141
/// include exceptions thrown in <see cref="IBasicConsumer"/> methods, or
142-
/// exceptions thrown in <see cref="ModelShutdownEventHandler"/> delegates etc.
142+
/// exceptions thrown in <see cref="ModelShutdown"/> delegates etc.
143143
/// </summary>
144144
event EventHandler<CallbackExceptionEventArgs> CallbackException;
145145

@@ -258,30 +258,18 @@ string BasicConsume(string queue,
258258
/// (Spec method) Convenience overload of BasicPublish.
259259
/// </summary>
260260
/// <remarks>
261-
/// The publication occurs with mandatory=false and immediate=false.
261+
/// The publication occurs with mandatory=false
262262
/// </remarks>
263263
[AmqpMethodDoNotImplement(null)]
264264
void BasicPublish(string exchange, string routingKey, IBasicProperties basicProperties, byte[] body);
265265

266266
/// <summary>
267267
/// (Spec method) Convenience overload of BasicPublish.
268268
/// </summary>
269-
/// <remarks>
270-
/// The publication occurs with immediate=false.
271-
/// </remarks>
272269
[AmqpMethodDoNotImplement(null)]
273270
void BasicPublish(string exchange, string routingKey, bool mandatory,
274271
IBasicProperties basicProperties, byte[] body);
275272

276-
/// <summary>(Spec method) Publish a message using the Basic
277-
///content-class.</summary>
278-
/// <remarks>
279-
///Note that the RabbitMQ server does not support the 'immediate' flag.
280-
/// </remarks>
281-
[AmqpMethodDoNotImplement(null)]
282-
void BasicPublish(string exchange, string routingKey, bool mandatory,
283-
bool immediate, IBasicProperties basicProperties, byte[] body);
284-
285273
/// <summary>
286274
/// (Spec method) Configures QoS parameters of the Basic content-class.
287275
/// </summary>

projects/client/RabbitMQ.Client/src/client/impl/AutorecoveringModel.cs

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -558,12 +558,11 @@ public void _Private_BasicGet(string queue, bool noAck)
558558
public void _Private_BasicPublish(string exchange,
559559
string routingKey,
560560
bool mandatory,
561-
bool immediate,
562561
IBasicProperties basicProperties,
563562
byte[] body)
564563
{
565564
m_delegate._Private_BasicPublish(exchange, routingKey, mandatory,
566-
immediate, basicProperties, body);
565+
basicProperties, body);
567566
}
568567

569568
public void _Private_BasicRecover(bool requeue)
@@ -844,17 +843,6 @@ public void BasicPublish(string exchange,
844843
body);
845844
}
846845

847-
public void BasicPublish(string exchange,
848-
string routingKey,
849-
bool mandatory,
850-
bool immediate,
851-
IBasicProperties basicProperties,
852-
byte[] body)
853-
{
854-
m_delegate.BasicPublish(exchange, routingKey, mandatory, immediate,
855-
basicProperties, body);
856-
}
857-
858846
public void BasicQos(uint prefetchSize,
859847
ushort prefetchCount,
860848
bool global)

projects/client/RabbitMQ.Client/src/client/impl/IFullModel.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,6 @@ void _Private_BasicGet(string queue,
225225
void _Private_BasicPublish(string exchange,
226226
string routingKey,
227227
bool mandatory,
228-
bool immediate,
229228
[AmqpContentHeaderMapping] IBasicProperties basicProperties,
230229
[AmqpContentBodyMapping] byte[] body);
231230

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1018,7 +1018,6 @@ public abstract void _Private_BasicGet(string queue,
10181018
public abstract void _Private_BasicPublish(string exchange,
10191019
string routingKey,
10201020
bool mandatory,
1021-
bool immediate,
10221021
IBasicProperties basicProperties,
10231022
byte[] body);
10241023

@@ -1216,21 +1215,6 @@ public void BasicPublish(string exchange,
12161215
bool mandatory,
12171216
IBasicProperties basicProperties,
12181217
byte[] body)
1219-
{
1220-
BasicPublish(exchange,
1221-
routingKey,
1222-
mandatory,
1223-
false,
1224-
basicProperties,
1225-
body);
1226-
}
1227-
1228-
public void BasicPublish(string exchange,
1229-
string routingKey,
1230-
bool mandatory,
1231-
bool immediate,
1232-
IBasicProperties basicProperties,
1233-
byte[] body)
12341218
{
12351219
if (basicProperties == null)
12361220
{
@@ -1250,7 +1234,6 @@ public void BasicPublish(string exchange,
12501234
_Private_BasicPublish(exchange,
12511235
routingKey,
12521236
mandatory,
1253-
immediate,
12541237
basicProperties,
12551238
body);
12561239
}

0 commit comments

Comments
 (0)