Class RabbitTemplate.DefaultTemplateConsumer

Namespace

Steeltoe.Messaging.RabbitMQ.Core

Assembly

Steeltoe.Messaging.RabbitMQ.dll

protected class RabbitTemplate.DefaultTemplateConsumer : RabbitTemplate.AbstractTemplateConsumer, IBasicConsumer

Inheritance

object

DefaultBasicConsumer

RabbitTemplate.AbstractTemplateConsumer

RabbitTemplate.DefaultTemplateConsumer

Implements

IBasicConsumer

Inherited Members

RabbitTemplate.AbstractTemplateConsumer.ToString()

DefaultBasicConsumer.m_eventLock

DefaultBasicConsumer.m_consumerCancelled

DefaultBasicConsumer.HandleBasicCancelOk(string)

DefaultBasicConsumer.OnCancel()

DefaultBasicConsumer.ConsumerTag

DefaultBasicConsumer.IsRunning

DefaultBasicConsumer.ShutdownReason

DefaultBasicConsumer.Model

DefaultBasicConsumer.ConsumerCancelled

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

Constructors

DefaultTemplateConsumer(IModel, CountdownEvent, TaskCompletionSource<Delivery>, string, CancellationToken)

public DefaultTemplateConsumer(IModel channel, CountdownEvent latch, TaskCompletionSource<Delivery> completionSource, string queueName, CancellationToken cancelationToken)

Parameters

channel IModel

latch CountdownEvent

completionSource TaskCompletionSource<Delivery>

queueName string

cancelationToken CancellationToken

Methods

HandleBasicCancel(string)

Called when the consumer is cancelled for reasons other than by a basicCancel: e.g. the queue has been deleted (either by this channel or by any other channel). See HandleBasicCancelOk(string) for notification of consumer cancellation due to basicCancel

public override void HandleBasicCancel(string consumerTag)

Parameters

consumerTag string

Consumer tag this consumer is registered.

HandleBasicConsumeOk(string)

Called upon successful registration of the consumer with the broker.

public override void HandleBasicConsumeOk(string consumerTag)

Parameters

consumerTag string

Consumer tag this consumer is registered.

HandleBasicDeliver(string, ulong, bool, string, string, IBasicProperties, byte[])

Called each time a message arrives for this consumer.

public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)

Parameters

consumerTag string

deliveryTag ulong

redelivered bool

exchange string

routingKey string

properties IBasicProperties

body byte[]

Remarks

Does nothing with the passed in information. Note that in particular, some delivered messages may require acknowledgement via BasicAck(ulong, bool). The implementation of this method in this class does NOT acknowledge such messages.

HandleModelShutdown(object, ShutdownEventArgs)

Called when the model shuts down.

public override void HandleModelShutdown(object model, ShutdownEventArgs reason)

Parameters

model object

Common AMQP model.

reason ShutdownEventArgs

Information about the reason why a particular model, session, or connection was destroyed.