Class CommittableIncomingMessage

Inheritance
Object
CommittableIncomingMessage
Inherited Members
Namespace: Akka.Streams.Amqp.RabbitMq.Dsl
Assembly: Akka.Streams.Amqp.RabbitMq.dll
Syntax
public sealed class CommittableIncomingMessage

Constructors

| Improve this Doc View Source

CommittableIncomingMessage(IncomingMessage, Func<Boolean, Task>, Func<Boolean, Boolean, Task>)

Declaration
public CommittableIncomingMessage(IncomingMessage message, Func<bool, Task> ack, Func<bool, bool, Task> nack)
Parameters
Type Name Description
IncomingMessage message
Func<Boolean, Task> ack
Func<Boolean, Boolean, Task> nack

Properties

| Improve this Doc View Source

Message

Declaration
public IncomingMessage Message { get; }
Property Value
Type Description
IncomingMessage

Methods

| Improve this Doc View Source

Ack(Boolean)

Declaration
public Task Ack(bool multiple = false)
Parameters
Type Name Description
Boolean multiple
Returns
Type Description
Task
| Improve this Doc View Source

Nack(Boolean, Boolean)

Declaration
public Task Nack(bool multiple = false, bool requeue = true)
Parameters
Type Name Description
Boolean multiple
Boolean requeue
Returns
Type Description
Task