Class AzureServiceBusMessageConsumer

Inheritance
object
AzureServiceBusMessageConsumer
Implements
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
Microsoft.Extensions.Logging.ILogger<TCategoryName><AzureServiceBusMessageConsumer>

Methods

HandleError(Exception)

Declaration
protected virtual Task HandleError(Exception exception)
Parameters
Type Name Description
System.Exception exception
Returns
Type Description
System.Threading.Tasks.Task

HandleIncomingError(ProcessErrorEventArgs)

Declaration
protected virtual Task HandleIncomingError(ProcessErrorEventArgs args)
Parameters
Type Name Description
Azure.Messaging.ServiceBus.ProcessErrorEventArgs args
Returns
Type Description
System.Threading.Tasks.Task

HandleIncomingMessage(ProcessMessageEventArgs)

Declaration
protected virtual Task HandleIncomingMessage(ProcessMessageEventArgs args)
Parameters
Type Name Description
Azure.Messaging.ServiceBus.ProcessMessageEventArgs args
Returns
Type Description
System.Threading.Tasks.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
System.Func<T, TResult><ServiceBusReceivedMessage, System.Threading.Tasks.Task> callback

StartProcessing()

Declaration
protected virtual void StartProcessing()

Implements

Extension Methods