Class TestConnectionRecovery.TestBasicConsumer
Inheritance
TestConnectionRecovery.TestBasicConsumer
Implements
Inherited Members
Namespace: RabbitMQ.Client.Unit
Assembly: Unit.dll
Syntax
public class TestConnectionRecovery.TestBasicConsumer : DefaultBasicConsumer, IBasicConsumer
Constructors
| Edit this page View SourceTestBasicConsumer(IModel, ushort, ManualResetEventSlim)
Declaration
public TestBasicConsumer(IModel model, ushort totalMessageCount, ManualResetEventSlim allMessagesSeenLatch)
Parameters
Type | Name | Description |
---|---|---|
IModel | model | |
ushort | totalMessageCount | |
ManualResetEventSlim | allMessagesSeenLatch |
Methods
| Edit this page View SourceHandleBasicDeliver(string, ulong, bool, string, string, IBasicProperties, ReadOnlyMemory<byte>)
Called each time a message is delivered for this consumer.
Declaration
public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, ReadOnlyMemory<byte> body)
Parameters
Type | Name | Description |
---|---|---|
string | consumerTag | |
ulong | deliveryTag | |
bool | redelivered | |
string | exchange | |
string | routingKey | |
IBasicProperties | properties | |
ReadOnlyMemory<byte> | body |
Overrides
Remarks
This is a no-op implementation. It will not acknowledge deliveries via BasicAck(ulong, bool) if consuming in automatic acknowledgement mode. Subclasses must copy or fully use delivery body before returning. Accessing the body at a later point is unsafe as its memory can be already released.
PostHandleDelivery(ulong)
Declaration
public virtual void PostHandleDelivery(ulong deliveryTag)
Parameters
Type | Name | Description |
---|---|---|
ulong | deliveryTag |