Class AzureServiceBusMessageConsumer

Inheritance

object

AzureServiceBusMessageConsumer

Implements

IAzureServiceBusMessageConsumer

ITransientDependency

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Volo.Abp.AzureServiceBus

Assembly: Volo.Abp.AzureServiceBus.dll

Syntax

public class AzureServiceBusMessageConsumer : IAzureServiceBusMessageConsumer, ITransientDependency

Constructors

AzureServiceBusMessageConsumer(IExceptionNotifier, IProcessorPool)

Declaration

public AzureServiceBusMessageConsumer(IExceptionNotifier exceptionNotifier, IProcessorPool processorPool)

Parameters

Type	Name	Description
IExceptionNotifier	exceptionNotifier
IProcessorPool	processorPool

Properties

Logger

Declaration

public ILogger<AzureServiceBusMessageConsumer> Logger { get; set; }

Property Value

Type	Description
ILogger<AzureServiceBusMessageConsumer>

Methods

HandleError(Exception)

Declaration

protected virtual Task HandleError(Exception exception)

Parameters

Type	Name	Description
Exception	exception

Returns

Type	Description
Task

HandleIncomingError(ProcessErrorEventArgs)

Declaration

protected virtual Task HandleIncomingError(ProcessErrorEventArgs args)

Parameters

Type	Name	Description
ProcessErrorEventArgs	args

Returns

Type	Description
Task

HandleIncomingMessage(ProcessMessageEventArgs)

Declaration

protected virtual Task HandleIncomingMessage(ProcessMessageEventArgs args)

Parameters

Type	Name	Description
ProcessMessageEventArgs	args

Returns

Type	Description
Task

Initialize(string, string, string?)

Declaration

public virtual void Initialize(string topicName, string subscriptionName, string? connectionName)

Parameters

Type	Name	Description
string	topicName
string	subscriptionName
string	connectionName

OnMessageReceived(Func<ServiceBusReceivedMessage, Task>)

Declaration

public void OnMessageReceived(Func<ServiceBusReceivedMessage, Task> callback)

Parameters

Type	Name	Description
Func<ServiceBusReceivedMessage, Task>	callback

StartProcessing()

Declaration

protected virtual void StartProcessing()

Implements

IAzureServiceBusMessageConsumer

ITransientDependency

Extension Methods

AbpObjectExtensions.As<T>(object)

AbpObjectExtensions.To<T>(object)

LockExtensions.Locking(object, Action)

LockExtensions.Locking<TResult>(object, Func<TResult>)

AbpObjectExtensions.If<T>(T, bool, Action<T>)

AbpObjectExtensions.If<T>(T, bool, Func<T, T>)

AbpObjectExtensions.IsIn<T>(T, IEnumerable<T>)

AbpObjectExtensions.IsIn<T>(T, params T[])

AbpQueryableExtensions.OrderByIf<T, TQueryable>(TQueryable, bool, string)

AbpQueryableExtensions.PageBy<T, TQueryable>(TQueryable, int, int)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, bool>>)

AbpQueryableExtensions.WhereIf<T, TQueryable>(TQueryable, bool, Expression<Func<T, int, bool>>)

AbpOpenIddictQueryableExtensions.SkipIf<T, TQueryable>(TQueryable, bool, int?)

AbpOpenIddictQueryableExtensions.TakeIf<T, TQueryable>(TQueryable, bool, int?)

LockExtensions.Locking<T>(T, Action<T>)

LockExtensions.Locking<T, TResult>(T, Func<T, TResult>)