Class RabbitTemplate.DoSendAndReceiveTemplateConsumer

Namespace

Steeltoe.Messaging.RabbitMQ.Core

Assembly

Steeltoe.Messaging.RabbitMQ.dll

protected class RabbitTemplate.DoSendAndReceiveTemplateConsumer : RabbitTemplate.AbstractTemplateConsumer, IBasicConsumer

Inheritance

object

DefaultBasicConsumer

RabbitTemplate.AbstractTemplateConsumer

RabbitTemplate.DoSendAndReceiveTemplateConsumer

Implements

IBasicConsumer

Inherited Members

RabbitTemplate.AbstractTemplateConsumer.ToString()

DefaultBasicConsumer.m_eventLock

DefaultBasicConsumer.m_consumerCancelled

DefaultBasicConsumer.HandleBasicCancel(string)

DefaultBasicConsumer.HandleBasicCancelOk(string)

DefaultBasicConsumer.HandleBasicConsumeOk(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

DoSendAndReceiveTemplateConsumer(RabbitTemplate, IModel, PendingReply)

public DoSendAndReceiveTemplateConsumer(RabbitTemplate template, IModel channel, RabbitTemplate.PendingReply pendingReply)

Parameters

template RabbitTemplate

channel IModel

pendingReply RabbitTemplate.PendingReply

Methods

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.