Skip to main content

RabbitMqWorker

Assembly: ServiceStack.RabbitMq.dll
View Source
Declaration
public class RabbitMqWorker : IDisposable

Properties

QueueName

View Source
Declaration
public string QueueName { get; set; }

AutoReconnect

View Source
Declaration
public bool AutoReconnect { get; set; }

Status

View Source
Declaration
public int Status { get; }

errorHandler

View Source
Declaration
public Action<RabbitMqWorker, Exception> errorHandler { get; set; }

LastMsgProcessed

View Source
Declaration
public DateTime LastMsgProcessed { get; }

TotalMessagesProcessed

View Source
Declaration
public int TotalMessagesProcessed { get; }

MsgNotificationsReceived

View Source
Declaration
public int MsgNotificationsReceived { get; }

MqClient

View Source
Declaration
public IMessageQueueClient MqClient { get; }

Fields

SleepTimeoutMs

View Source
Declaration
public int SleepTimeoutMs

Methods

Clone()

View Source
Declaration
public virtual RabbitMqWorker Clone()
Returns

ServiceStack.RabbitMq.RabbitMqWorker

Start()

View Source
Declaration
public virtual void Start()

ForceRestart()

View Source
Declaration
public virtual void ForceRestart()

Stop()

View Source
Declaration
public virtual void Stop()

Dispose()

View Source
Declaration
public virtual void Dispose()

GetStats()

View Source
Declaration
public virtual IMessageHandlerStats GetStats()
Returns

ServiceStack.Messaging.IMessageHandlerStats

GetStatus()

View Source
Declaration
public virtual string GetStatus()
Returns

System.String

Implements

  • System.IDisposable