Skip to content

Commit 7a70bab

Browse files
author
Alexandru Scvortov
committed
added nowait variant of Model.ConfirmSelect
1 parent b3cb701 commit 7a70bab

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,12 @@ uint QueueDelete(string queue,
281281
[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]
282282
void ConfirmSelect(bool multiple);
283283

284+
///<summary>Enable publisher acknowledgements.</summary>
285+
[AmqpMethodDoNotImplement(null)]
286+
[AmqpUnsupported("RabbitMQ.Client.Framing.v0_8qpid")]
287+
void ConfirmSelect(bool multiple, bool nowait);
288+
289+
284290
///<summary>Start a Basic content-class consumer.</summary>
285291
///<remarks>
286292
///The consumer is started with noAck=false (i.e. BasicAck is required),

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -627,10 +627,15 @@ public abstract uint QueueDelete(string queue,
627627
bool nowait);
628628

629629
public void ConfirmSelect(bool multiple) {
630+
ConfirmSelect(multiple, false);
631+
}
632+
633+
public void ConfirmSelect(bool multiple, bool nowait) {
630634
m_pubMsgCount = 0;
631-
_Private_ConfirmSelect(multiple, false);
635+
_Private_ConfirmSelect(multiple, nowait);
632636
}
633637

638+
634639
public abstract void _Private_ConfirmSelect(bool multiple,
635640
bool nowait);
636641

0 commit comments

Comments
 (0)