RabbitMqQueueClient
Assembly: ServiceStack.RabbitMq.dll
View Source
Declaration
public class RabbitMqQueueClient : RabbitMqProducer, IOneWayClient, IMessageQueueClient, IMessageProducer, IDisposable
Inherited Properties
Channel
View Source
Declaration
public IModel Channel { get; }
Connection
View Source
Declaration
public IConnection Connection { get; }
GetMessageFilter
View Source
Declaration
public Action<string, BasicGetResult> GetMessageFilter { get; set; }
OnPublishedCallback
View Source
Declaration
public Action OnPublishedCallback { get; set; }
PrefetchCount
View Source
Declaration
public ushort PrefetchCount { get; set; }
PublishMessageFilter
View Source
Declaration
public Action<string, IBasicProperties, IMessage> PublishMessageFilter { get; set; }
RetryCount
View Source
Declaration
public int RetryCount { get; set; }
Methods
Notify(String, IMessage)
View Source
Declaration
public virtual 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 virtual 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 virtual 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 virtual void Ack(IMessage message)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessage | message |
Nak(IMessage, Boolean, Exception)
View Source
Declaration
public virtual 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 virtual 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 virtual string GetTempQueueName()
Returns
System.String
Inherited Methods
Dispose()
View Source
Declaration
public virtual void Dispose()
GetMessage(String, Boolean)
View Source
Declaration
public virtual BasicGetResult GetMessage(string queueName, bool noAck)
Returns
BasicGetResult
Parameters
| Type | Name |
|---|---|
System.String | queueName |
System.Boolean | noAck |
Publish(String, IMessage)
View Source
Declaration
public virtual void Publish(string queueName, IMessage message)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
| ServiceStack.Messaging.IMessage | message |
Publish(String, IMessage, String)
View Source
Declaration
public virtual void Publish(string queueName, IMessage message, string exchange)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
| ServiceStack.Messaging.IMessage | message |
System.String | exchange |
Publish<T>(T)
View Source
Declaration
public virtual void Publish<T>(T messageBody)
Parameters
| Type | Name |
|---|---|
<T> | messageBody |
Type Parameters
T
Publish<T>(IMessage<T>)
View Source
Declaration
public virtual void Publish<T>(IMessage<T> message)
Parameters
| Type | Name |
|---|---|
| ServiceStack.Messaging.IMessage<T> | message |
Type Parameters
T
PublishMessage(String, String, IBasicProperties, Byte[])
View Source
Declaration
public virtual void PublishMessage(string exchange, string routingKey, IBasicProperties basicProperties, byte[] body)
Parameters
| Type | Name |
|---|---|
System.String | exchange |
System.String | routingKey |
IBasicProperties | basicProperties |
System.Byte[] | body |
SendAllOneWay(IEnumerable<Object>)
View Source
Declaration
public virtual void SendAllOneWay(IEnumerable<object> requests)
Parameters
| Type | Name |
|---|---|
System.Collections.Generic.IEnumerable<System.Object> | requests |
SendOneWay(Object)
View Source
Declaration
public virtual void SendOneWay(object requestDto)
Parameters
| Type | Name |
|---|---|
System.Object | requestDto |
SendOneWay(String, Object)
View Source
Declaration
public virtual void SendOneWay(string queueName, object requestDto)
Parameters
| Type | Name |
|---|---|
System.String | queueName |
System.Object | requestDto |