Known direct subtypes:
DefaultBasicConsumer
See IModel.BasicConsume, IModel.BasicCancel.
Note that the "Handle*" methods run in the connection's thread! Consider using QueueingBasicConsumer, which uses a SharedQueue instance to safely pass received messages across to user threads.
| Type | Name | Summary |
|---|---|---|
IModel
|
Model
(r)
|
Retrieve the IModel this consumer is associated with, for use in acknowledging received messages, for instance. |
| Name | Summary |
|---|---|
void HandleBasicCancelOk(string consumerTag)
|
Called upon successful deregistration of the consumer from the broker. |
void HandleBasicConsumeOk(string consumerTag)
|
Called upon successful registration of the consumer with the broker. |
void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
|
Called each time a message arrives for this consumer. |
void HandleModelShutdown(IModel model, ShutdownEventArgs reason)
|
Called when the model shuts down. |
void HandleBasicCancelOk(string consumerTag)
| Return type |
void
|
||||
|---|---|---|---|---|---|
| Parameters |
|
void HandleBasicConsumeOk(string consumerTag)
| Return type |
void
|
||||
|---|---|---|---|---|---|
| Parameters |
|
void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
| Return type |
void
|
||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Parameters |
|
void HandleModelShutdown(IModel model, ShutdownEventArgs reason)
| Return type |
void
|
||||||
|---|---|---|---|---|---|---|---|
| Parameters |
|