Skip to content

Commit ed3e56a

Browse files
author
petrov-e
committed
remove byte[] overload
1 parent 1e1282f commit ed3e56a

File tree

5 files changed

+0
-64
lines changed

5 files changed

+0
-64
lines changed

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

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -221,18 +221,6 @@ string BasicConsume(
221221
/// <summary>Reject one or more delivered message(s).</summary>
222222
void BasicNack(ulong deliveryTag, bool multiple, bool requeue);
223223

224-
/// <summary>
225-
/// Publishes a message.
226-
/// </summary>
227-
/// <remarks>
228-
/// <para>
229-
/// Routing key must be shorter than 255 bytes.
230-
/// </para>
231-
/// </remarks>
232-
[AmqpMethodDoNotImplement(null)]
233-
void BasicPublish(string exchange, string routingKey, bool mandatory,
234-
IBasicProperties basicProperties, byte[] body);
235-
236224
/// <summary>
237225
/// Publishes a message.
238226
/// </summary>

projects/RabbitMQ.Client/client/api/IModelExtensions.cs

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -83,17 +83,6 @@ public static string BasicConsume(this IModel model, string queue,
8383
return model.BasicConsume(queue, autoAck, consumerTag, false, false, arguments, consumer);
8484
}
8585

86-
/// <summary>
87-
/// (Extension method) Convenience overload of BasicPublish.
88-
/// </summary>
89-
/// <remarks>
90-
/// The publication occurs with mandatory=false and immediate=false.
91-
/// </remarks>
92-
public static void BasicPublish(this IModel model, PublicationAddress addr, IBasicProperties basicProperties, byte[] body)
93-
{
94-
model.BasicPublish(addr.ExchangeName, addr.RoutingKey, basicProperties: basicProperties, body: body);
95-
}
96-
9786
/// <summary>
9887
/// (Extension method) Convenience overload of BasicPublish.
9988
/// </summary>
@@ -105,17 +94,6 @@ public static void BasicPublish(this IModel model, PublicationAddress addr, IBas
10594
model.BasicPublish(addr.ExchangeName, addr.RoutingKey, basicProperties: basicProperties, body: body);
10695
}
10796

108-
/// <summary>
109-
/// (Extension method) Convenience overload of BasicPublish.
110-
/// </summary>
111-
/// <remarks>
112-
/// The publication occurs with mandatory=false
113-
/// </remarks>
114-
public static void BasicPublish(this IModel model, string exchange, string routingKey, IBasicProperties basicProperties, byte[] body)
115-
{
116-
model.BasicPublish(exchange, routingKey, false, basicProperties, body);
117-
}
118-
11997
/// <summary>
12098
/// (Extension method) Convenience overload of BasicPublish.
12199
/// </summary>
@@ -127,14 +105,6 @@ public static void BasicPublish(this IModel model, string exchange, string routi
127105
model.BasicPublish(exchange, routingKey, false, basicProperties, body);
128106
}
129107

130-
/// <summary>
131-
/// (Spec method) Convenience overload of BasicPublish.
132-
/// </summary>
133-
public static void BasicPublish(this IModel model, string exchange, string routingKey, bool mandatory = false, IBasicProperties basicProperties = null, byte[] body = null)
134-
{
135-
model.BasicPublish(exchange, routingKey, mandatory, basicProperties, body);
136-
}
137-
138108
/// <summary>
139109
/// (Spec method) Convenience overload of BasicPublish.
140110
/// </summary>

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

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -802,15 +802,6 @@ public void BasicNack(ulong deliveryTag,
802802
_delegate.BasicNack(deliveryTag, multiple, requeue);
803803
}
804804

805-
public void BasicPublish(string exchange,
806-
string routingKey,
807-
bool mandatory,
808-
IBasicProperties basicProperties,
809-
byte[] body)
810-
{
811-
BasicPublish(exchange, routingKey, mandatory, basicProperties, new ReadOnlyMemory<byte>(body));
812-
}
813-
814805
public void BasicPublish(string exchange,
815806
string routingKey,
816807
bool mandatory,

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

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1096,15 +1096,6 @@ internal void AllocatatePublishSeqNos(int count)
10961096
}
10971097
}
10981098

1099-
public void BasicPublish(string exchange,
1100-
string routingKey,
1101-
bool mandatory,
1102-
IBasicProperties basicProperties,
1103-
byte[] body)
1104-
{
1105-
BasicPublish(exchange, routingKey, mandatory, basicProperties, new ReadOnlyMemory<byte>(body));
1106-
}
1107-
11081099
public void BasicPublish(string exchange,
11091100
string routingKey,
11101101
bool mandatory,

projects/Unit/APIApproval.Approve.approved.txt

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,6 @@ namespace RabbitMQ.Client
353353
string BasicConsume(string queue, bool autoAck, string consumerTag, bool noLocal, bool exclusive, System.Collections.Generic.IDictionary<string, object> arguments, RabbitMQ.Client.IBasicConsumer consumer);
354354
RabbitMQ.Client.BasicGetResult BasicGet(string queue, bool autoAck);
355355
void BasicNack(ulong deliveryTag, bool multiple, bool requeue);
356-
void BasicPublish(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties basicProperties, byte[] body);
357356
void BasicPublish(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory<byte> body);
358357
void BasicQos(uint prefetchSize, ushort prefetchCount, bool global);
359358
void BasicRecover(bool requeue);
@@ -399,11 +398,8 @@ namespace RabbitMQ.Client
399398
public static string BasicConsume(this RabbitMQ.Client.IModel model, string queue, bool autoAck, string consumerTag, RabbitMQ.Client.IBasicConsumer consumer) { }
400399
public static string BasicConsume(this RabbitMQ.Client.IModel model, string queue, bool autoAck, string consumerTag, System.Collections.Generic.IDictionary<string, object> arguments, RabbitMQ.Client.IBasicConsumer consumer) { }
401400
public static string BasicConsume(this RabbitMQ.Client.IModel model, RabbitMQ.Client.IBasicConsumer consumer, string queue, bool autoAck = false, string consumerTag = "", bool noLocal = false, bool exclusive = false, System.Collections.Generic.IDictionary<string, object> arguments = null) { }
402-
public static void BasicPublish(this RabbitMQ.Client.IModel model, RabbitMQ.Client.PublicationAddress addr, RabbitMQ.Client.IBasicProperties basicProperties, byte[] body) { }
403401
public static void BasicPublish(this RabbitMQ.Client.IModel model, RabbitMQ.Client.PublicationAddress addr, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory<byte> body) { }
404-
public static void BasicPublish(this RabbitMQ.Client.IModel model, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties basicProperties, byte[] body) { }
405402
public static void BasicPublish(this RabbitMQ.Client.IModel model, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory<byte> body) { }
406-
public static void BasicPublish(this RabbitMQ.Client.IModel model, string exchange, string routingKey, bool mandatory = false, RabbitMQ.Client.IBasicProperties basicProperties = null, byte[] body = null) { }
407403
public static void BasicPublish(this RabbitMQ.Client.IModel model, string exchange, string routingKey, bool mandatory = false, RabbitMQ.Client.IBasicProperties basicProperties = null, System.ReadOnlyMemory<byte> body = default) { }
408404
public static void ExchangeBind(this RabbitMQ.Client.IModel model, string destination, string source, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments = null) { }
409405
public static void ExchangeBindNoWait(this RabbitMQ.Client.IModel model, string destination, string source, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments = null) { }

0 commit comments

Comments
 (0)