InMemoryTransientMessageService
Assembly: ServiceStack.dll
View Source
Declaration
public class InMemoryTransientMessageService : TransientMessageServiceBase, IMessageService, IDisposable, IMessageHandlerDisposer
Properties
MessageFactory
View Source
Declaration
public override IMessageFactory MessageFactory { get; }
MessageQueueFactory
View Source
Declaration
public MessageQueueClientFactory MessageQueueFactory { get; }
Inherited Properties
MessageFactory
View Source
Declaration
public abstract IMessageFactory MessageFactory { get; }
PoolSize
View Source
Declaration
public int PoolSize { get; protected set; }
RegisteredTypes
View Source
Declaration
public List<Type> RegisteredTypes { get; }
RequestTimeOut
View Source
Declaration
public TimeSpan? RequestTimeOut { get; protected set; }
RetryCount
View Source
Declaration
public int RetryCount { get; set; }
Inherited Methods
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
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 |
GetStats()
View Source
Declaration
public IMessageHandlerStats GetStats()
Returns
ServiceStack.Messaging.IMessageHandlerStats
GetStatsDescription()
View Source
Declaration
public string GetStatsDescription()
Returns
System.String
GetStatus()
View Source
Declaration
public string GetStatus()
Returns
System.String
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>, 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
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
Start()
View Source
Declaration
public virtual void Start()
Stop()
View Source
Declaration
public virtual void Stop()