IMessageQueueClient
Assembly: ServiceStack.Interfaces.dll
View Source
Declaration
public interface IMessageQueueClient : IMessageProducer, IDisposable
Methods
Publish(String, IMessage)
Publish the specified message into the durable queue @queueName
View Source
Declaration
void Publish(string queueName, IMessage message)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
| ServiceStack.Messaging.IMessage | message |
Notify(String, IMessage)
Publish the specified message into the transient queue @queueName
View Source
Declaration
void Notify(string queueName, IMessage message)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
| ServiceStack.Messaging.IMessage | message |
Get<T>(String, Nullable<TimeSpan>)
Synchronous blocking get.
View Source
Declaration
IMessage<T> Get<T>(string queueName, TimeSpan? timeOut = null)
Returns
ServiceStack.Messaging.IMessage<T>
Parameters
| Type | Name |
|---|---|
System.String | queueName |
System.Nullable<System.TimeSpan> | timeOut |
Type Parameters
T
GetAsync<T>(String)
Non blocking get message
View Source
Declaration
IMessage<T> GetAsync<T>(string queueName)
Returns
ServiceStack.Messaging.IMessage<T>
Parameters
| Type | Name |
|---|---|
System.String | queueName |
Type Parameters
T
Ack(IMessage)
Acknowledge the message has been successfully received or processed
View Source
Declaration
void Ack(IMessage message)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessage | message |
Nak(IMessage, Boolean, Exception)
Negative acknowledgement the message was not processed correctly
View Source
Declaration
void Nak(IMessage message, bool requeue, Exception exception = null)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessage | message |
System.Boolean | requeue |
System.Exception | exception |
CreateMessage<T>(Object)
Create a typed message from a raw MQ Response artefact
View Source
Declaration
IMessage<T> CreateMessage<T>(object mqResponse)
Returns
ServiceStack.Messaging.IMessage<T>
Parameters
| Type | Name |
|---|---|
System.Object | mqResponse |
Type Parameters
T
GetTempQueueName()
Create a temporary Queue for Request / Reply
View Source
Declaration
string GetTempQueueName()
Returns
System.String