Skip to main content

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
TypeName
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
TypeName
ServiceStack.Messaging.IMessageHandlermessageHandler

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
TypeName
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
TypeName
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
TypeName
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object>processMessageFn
System.Action<ServiceStack.Messaging.IMessageHandler,ServiceStack.Messaging.IMessage<<T>>,System.Exception>processExceptionEx
System.Int32noOfThreads
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
TypeName
System.Func<ServiceStack.Messaging.IMessage<<T>>,System.Object>processMessageFn
System.Int32noOfThreads
Type Parameters
  • T

Start()

View Source
Declaration
public virtual void Start()

Stop()

View Source
Declaration
public virtual void Stop()

Implements