RedisMessageQueueClient
Assembly: ServiceStack.Client.dll
View Source
Declaration
public class RedisMessageQueueClient : IMessageQueueClient, IMessageProducer, IDisposable, IOneWayClient
Properties
MaxSuccessQueueSize
View Source
Declaration
public int MaxSuccessQueueSize { get; set; }
ReadWriteClient
View Source
Declaration
public IRedisNativeClient ReadWriteClient { get; }
ReadOnlyClient
View Source
Declaration
public IRedisNativeClient ReadOnlyClient { get; }
Methods
Publish<T>(T)
View Source
Declaration
public void Publish<T>(T messageBody)
Parameters
| Type | Name |
|---|---|
<T> | messageBody |
Type Parameters
T
Publish<T>(IMessage<T>)
View Source
Declaration
public void Publish<T>(IMessage<T> message)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessage<T> | message |
Type Parameters
T
SendOneWay(Object)
View Source
Declaration
public void SendOneWay(object requestDto)
Parameters
| Type | Name |
|---|---|
System.Object | requestDto |
SendOneWay(String, Object)
View Source
Declaration
public void SendOneWay(string queueName, object requestDto)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
System.Object | requestDto |
SendAllOneWay(IEnumerable<Object>)
View Source
Declaration
public void SendAllOneWay(IEnumerable<object> requests)
Parameters
| Type | Name |
|---|---|
System.Collections.Generic.IEnumerable<System.Object> | requests |
Publish(String, IMessage)
View Source
Declaration
public void Publish(string queueName, IMessage message)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
| ServiceStack.Messaging.IMessage | message |
Notify(String, IMessage)
View Source
Declaration
public void Notify(string queueName, IMessage message)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
| ServiceStack.Messaging.IMessage | message |
Get<T>(String, Nullable<TimeSpan>)
View Source
Declaration
public 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)
View Source
Declaration
public IMessage<T> GetAsync<T>(string queueName)
Returns
ServiceStack.Messaging.IMessage<T>
Parameters
| Type | Name |
|---|---|
System.String | queueName |
Type Parameters
T
Ack(IMessage)
View Source
Declaration
public void Ack(IMessage message)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessage | message |
Nak(IMessage, Boolean, Exception)
View Source
Declaration
public 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)
View Source
Declaration
public IMessage<T> CreateMessage<T>(object mqResponse)
Returns
ServiceStack.Messaging.IMessage<T>
Parameters
| Type | Name |
|---|---|
System.Object | mqResponse |
Type Parameters
T
GetTempQueueName()
View Source
Declaration
public string GetTempQueueName()
Returns
System.String
Dispose()
View Source
Declaration
public void Dispose()