IMessageHandler
Single threaded message handler that can process all messages of a particular message type.
Assembly: ServiceStack.Interfaces.dll
View Source
Declaration
public interface IMessageHandler
Properties
MessageType
The type of the message this handler processes
View Source
Declaration
Type MessageType { get; }
MqClient
The MqClient processing the message
View Source
Declaration
IMessageQueueClient MqClient { get; }
Methods
Process(IMessageQueueClient)
Process all messages pending
View Source
Declaration
void Process(IMessageQueueClient mqClient)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessageQueueClient | mqClient |
ProcessQueue(IMessageQueueClient, String, Func<Boolean>)
Process messages from a single queue.
View Source
Declaration
int ProcessQueue(IMessageQueueClient mqClient, string queueName, Func<bool> doNext = null)
Returns
System.Int32
Parameters
| Type | Name | Description |
|---|---|---|
| ServiceStack.Messaging.IMessageQueueClient | mqClient |
|
| System.String | queueName | The queue to process
|
| System.Func<System.Boolean> | doNext | A predicate on whether to continue processing the next message if any
|
ProcessMessage(IMessageQueueClient, Object)
Process a single message
View Source
Declaration
void ProcessMessage(IMessageQueueClient mqClient, object mqResponse)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessageQueueClient | mqClient |
System.Object | mqResponse |
GetStats()
Get Current Stats for this Message Handler
View Source
Declaration
IMessageHandlerStats GetStats()