Skip to content

Commit 1dec1d1

Browse files
committed
* Remove QueueUnbind
1 parent e6d0a95 commit 1dec1d1

File tree

6 files changed

+9
-3
lines changed

6 files changed

+9
-3
lines changed

projects/RabbitMQ.Client/PublicAPI.Unshipped.txt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -498,7 +498,6 @@ RabbitMQ.Client.IChannel.FlowControl -> System.EventHandler<RabbitMQ.Client.Even
498498
RabbitMQ.Client.IChannel.IsClosed.get -> bool
499499
RabbitMQ.Client.IChannel.IsOpen.get -> bool
500500
RabbitMQ.Client.IChannel.NextPublishSeqNo.get -> ulong
501-
RabbitMQ.Client.IChannel.QueueUnbind(string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments) -> void
502501
RabbitMQ.Client.IChannel.TxCommit() -> void
503502
RabbitMQ.Client.IChannel.TxRollback() -> void
504503
RabbitMQ.Client.IChannel.TxSelect() -> void
@@ -862,7 +861,6 @@ static RabbitMQ.Client.IChannelExtensions.BasicConsume(this RabbitMQ.Client.ICha
862861
static RabbitMQ.Client.IChannelExtensions.BasicPublishAsync(this RabbitMQ.Client.IChannel channel, RabbitMQ.Client.CachedString exchange, RabbitMQ.Client.CachedString routingKey, System.ReadOnlyMemory<byte> body = default(System.ReadOnlyMemory<byte>), bool mandatory = false) -> System.Threading.Tasks.ValueTask
863862
static RabbitMQ.Client.IChannelExtensions.BasicPublishAsync(this RabbitMQ.Client.IChannel channel, string exchange, string routingKey, System.ReadOnlyMemory<byte> body = default(System.ReadOnlyMemory<byte>), bool mandatory = false) -> System.Threading.Tasks.ValueTask
864863
static RabbitMQ.Client.IChannelExtensions.BasicPublishAsync<T>(this RabbitMQ.Client.IChannel channel, RabbitMQ.Client.PublicationAddress addr, in T basicProperties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.ValueTask
865-
static RabbitMQ.Client.IChannelExtensions.QueueUnbind(this RabbitMQ.Client.IChannel channel, string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments = null) -> void
866864
static RabbitMQ.Client.PublicationAddress.Parse(string uriLikeString) -> RabbitMQ.Client.PublicationAddress
867865
static RabbitMQ.Client.PublicationAddress.TryParse(string uriLikeString, out RabbitMQ.Client.PublicationAddress result) -> bool
868866
static RabbitMQ.Client.QueueDeclareOk.implicit operator string(RabbitMQ.Client.QueueDeclareOk declareOk) -> string

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -624,6 +624,7 @@ Task<QueueDeclareOk> QueueDeclareAsync(string queue, bool durable, bool exclusiv
624624
/// <returns>Returns the number of messages purged.</returns>
625625
Task<uint> QueuePurgeAsync(string queue);
626626

627+
#if SYNC_API
627628
/// <summary>
628629
/// Unbind a queue from an exchange.
629630
/// </summary>
@@ -635,6 +636,7 @@ Task<QueueDeclareOk> QueueDeclareAsync(string queue, bool durable, bool exclusiv
635636
/// Routing key must be shorter than 255 bytes.
636637
/// </remarks>
637638
void QueueUnbind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments);
639+
#endif
638640

639641
/// <summary>
640642
/// Asynchronously unbind a queue from an exchange.

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,6 @@ public static void QueueDeleteNoWait(this IChannel channel, string queue, bool i
287287
{
288288
channel.QueueDeleteNoWait(queue, ifUnused, ifEmpty);
289289
}
290-
#endif
291290

292291
/// <summary>
293292
/// Unbinds a queue.
@@ -296,6 +295,7 @@ public static void QueueUnbind(this IChannel channel, string queue, string excha
296295
{
297296
channel.QueueUnbind(queue, exchange, routingKey, arguments);
298297
}
298+
#endif
299299

300300
/// <summary>
301301
/// Asynchronously unbinds a queue.

projects/RabbitMQ.Client/client/framing/Channel.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -251,10 +251,12 @@ public override Task BasicRejectAsync(ulong deliveryTag, bool requeue)
251251
return ModelSendAsync(method).AsTask();
252252
}
253253

254+
#if SYNC_API
254255
public override void QueueUnbind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
255256
{
256257
ChannelRpc(new QueueUnbind(queue, exchange, routingKey, arguments), ProtocolCommandId.QueueUnbindOk);
257258
}
259+
#endif
258260

259261
public override void TxCommit()
260262
{

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -623,6 +623,7 @@ public uint QueuePurge(string queue)
623623
public Task<uint> QueuePurgeAsync(string queue)
624624
=> InnerChannel.QueuePurgeAsync(queue);
625625

626+
#if SYNC_API
626627
public void QueueUnbind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
627628
{
628629
ThrowIfDisposed();
@@ -631,6 +632,7 @@ public void QueueUnbind(string queue, string exchange, string routingKey, IDicti
631632
_innerChannel.QueueUnbind(queue, exchange, routingKey, arguments);
632633
_connection.DeleteAutoDeleteExchange(exchange, recordedEntitiesSemaphoreHeld: false);
633634
}
635+
#endif
634636

635637
public async Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
636638
{

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1887,7 +1887,9 @@ await ModelSendAsync(method)
18871887
}
18881888
}
18891889

1890+
#if SYNC_API
18901891
public abstract void QueueUnbind(string queue, string exchange, string routingKey, IDictionary<string, object> arguments);
1892+
#endif
18911893

18921894
public async Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments)
18931895
{

0 commit comments

Comments
 (0)