TransientMessageServiceBase
Assembly: ServiceStack.dll
View Source
Declaration
public abstract class TransientMessageServiceBase : IMessageService, IDisposable, IMessageHandlerDisposer
Properties
RetryCount
View Source
Declaration
public int RetryCount { get; set; }
RequestTimeOut
View Source
Declaration
public TimeSpan? RequestTimeOut { get; protected set; }
PoolSize
View Source
Declaration
public int PoolSize { get; protected set; }
MessageFactory
View Source
Declaration
public abstract IMessageFactory MessageFactory { get; }
RegisteredTypes
View Source
Declaration
public List<Type> RegisteredTypes { get; }
Fields
DefaultRetryCount
View Source
Declaration
public const int DefaultRetryCount = 2
Methods
RegisterHandler<T>(Func<IMessage<T>, Object>)
View Source
Declaration
public void RegisterHandler<T>(Func<IMessage<T>, object> processMessageFn)
Parameters
| Type | Name |
|---|---|
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object> | processMessageFn |
Type Parameters
T
RegisterHandler<T>(Func<IMessage<T>, Object>, Int32)
View Source
Declaration
public void RegisterHandler<T>(Func<IMessage<T>, object> processMessageFn, int noOfThreads)
Parameters
| Type | Name |
|---|---|
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object> | processMessageFn |
System.Int32 | noOfThreads |
Type Parameters
T
RegisterHandler<T>(Func<IMessage<T>, Object>, Action<IMessageHandler, IMessage<T>, Exception>)
View Source
Declaration
public void RegisterHandler<T>(Func<IMessage<T>, object> processMessageFn, Action<IMessageHandler, IMessage<T>, Exception> processExceptionEx)
Parameters
| Type | Name |
|---|---|
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object> | processMessageFn |
System.Action<ServiceStack.Messaging.IMessageHandler,ServiceStack.Messaging.IMessage<<T>>,System.Exception> | processExceptionEx |
Type Parameters
T
RegisterHandler<T>(Func<IMessage<T>, Object>, Action<IMessageHandler, IMessage<T>, Exception>, Int32)
View Source
Declaration
public void RegisterHandler<T>(Func<IMessage<T>, object> processMessageFn, Action<IMessageHandler, IMessage<T>, Exception> processExceptionEx, int noOfThreads)
Parameters
| Type | Name |
|---|---|
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object> | processMessageFn |
System.Action<ServiceStack.Messaging.IMessageHandler,ServiceStack.Messaging.IMessage<<T>>,System.Exception> | processExceptionEx |
System.Int32 | noOfThreads |
Type Parameters
T
GetStats()
View Source
Declaration
public IMessageHandlerStats GetStats()
Returns
ServiceStack.Messaging.IMessageHandlerStats
GetStatus()
View Source
Declaration
public string GetStatus()
Returns
System.String
GetStatsDescription()
View Source
Declaration
public string GetStatsDescription()
Returns
System.String
CreateMessageHandlerFactory<T>(Func<IMessage<T>, Object>, Action<IMessageHandler, IMessage<T>, Exception>)
View Source
Declaration
protected IMessageHandlerFactory CreateMessageHandlerFactory<T>(Func<IMessage<T>, object> processMessageFn, Action<IMessageHandler, IMessage<T>, Exception> processExceptionEx)
Returns
ServiceStack.Messaging.IMessageHandlerFactory
Parameters
| Type | Name |
|---|---|
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object> | processMessageFn |
System.Action<ServiceStack.Messaging.IMessageHandler,ServiceStack.Messaging.IMessage<<T>>,System.Exception> | processExceptionEx |
Type Parameters
T
Start()
View Source
Declaration
public virtual void Start()
Stop()
View Source
Declaration
public virtual void Stop()
Dispose()
View Source
Declaration
public virtual void Dispose()
DisposeMessageHandler(IMessageHandler)
View Source
Declaration
public virtual void DisposeMessageHandler(IMessageHandler messageHandler)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessageHandler | messageHandler |