X

Class DirectMessageListenerContainer.SimpleConsumer

Inheritance
System.Object
DirectMessageListenerContainer.SimpleConsumer
Namespace: Steeltoe.Messaging.RabbitMQ.Listener
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
protected class SimpleConsumer : RabbitMQ.Client.DefaultBasicConsumer

Constructors

| Edit this page View Source

SimpleConsumer(DirectMessageListenerContainer, IConnection, RabbitMQ.Client.IModel, String, ILogger)

Declaration
public SimpleConsumer(DirectMessageListenerContainer container, IConnection connection, RabbitMQ.Client.IModel channel, string queue, ILogger logger = null)
Parameters
Type Name Description
DirectMessageListenerContainer container
IConnection connection
RabbitMQ.Client.IModel channel
System.String queue
ILogger logger

Properties

| Edit this page View Source

AckFailed

Declaration
public bool AckFailed { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

AckRequired

Declaration
public bool AckRequired { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

AckTimeout

Declaration
public long AckTimeout { get; }
Property Value
Type Description
System.Int64
| Edit this page View Source

Canceled

Declaration
public bool Canceled { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

ConnectionFactory

Declaration
public IConnectionFactory ConnectionFactory { get; }
Property Value
Type Description
IConnectionFactory
| Edit this page View Source

Epoch

Declaration
public int Epoch { get; }
Property Value
Type Description
System.Int32
| Edit this page View Source

IsRabbitTxManager

Declaration
public bool IsRabbitTxManager { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

LastAck

Declaration
public long LastAck { get; }
Property Value
Type Description
System.Int64
| Edit this page View Source

LatestDeferredDeliveryTag

Declaration
public ulong LatestDeferredDeliveryTag { get; }
Property Value
Type Description
System.UInt64
| Edit this page View Source

MessagesPerAck

Declaration
public int MessagesPerAck { get; }
Property Value
Type Description
System.Int32
| Edit this page View Source

PendingAcks

Declaration
public int PendingAcks { get; }
Property Value
Type Description
System.Int32
| Edit this page View Source

Queue

Declaration
public string Queue { get; }
Property Value
Type Description
System.String
| Edit this page View Source

TargetChanged

Declaration
public bool TargetChanged { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

TransactionAttribute

Declaration
public ITransactionAttribute TransactionAttribute { get; }
Property Value
Type Description
ITransactionAttribute
| Edit this page View Source

TransactionManager

Declaration
public IPlatformTransactionManager TransactionManager { get; }
Property Value
Type Description
IPlatformTransactionManager
| Edit this page View Source

TransactionTemplate

Declaration
public TransactionTemplate TransactionTemplate { get; }
Property Value
Type Description
TransactionTemplate

Methods

| Edit this page View Source

HandleBasicCancel(String)

Declaration
public override void HandleBasicCancel(string consumerTag)
Parameters
Type Name Description
System.String consumerTag
| Edit this page View Source

HandleBasicCancelOk(String)

Declaration
public override void HandleBasicCancelOk(string consumerTag)
Parameters
Type Name Description
System.String consumerTag
| Edit this page View Source

HandleBasicConsumeOk(String)

Declaration
public override void HandleBasicConsumeOk(string consumerTag)
Parameters
Type Name Description
System.String consumerTag
| Edit this page View Source

HandleBasicDeliver(String, UInt64, Boolean, String, String, RabbitMQ.Client.IBasicProperties, Byte[])

Declaration
public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, byte[] body)
Parameters
Type Name Description
System.String consumerTag
System.UInt64 deliveryTag
System.Boolean redelivered
System.String exchange
System.String routingKey
RabbitMQ.Client.IBasicProperties properties
System.Byte[] body
| Edit this page View Source

IncrementAndGetEpoch()

Declaration
public int IncrementAndGetEpoch()
Returns
Type Description
System.Int32
| Edit this page View Source

ToString()

Declaration
public override string ToString()
Returns
Type Description
System.String