Skip to main content

RabbitMqProducer

Assembly: ServiceStack.RabbitMq.dll​
View Source​
Declaration
public class RabbitMqProducer : IMessageProducer, IDisposable, IOneWayClient

Properties​

RetryCount​

View Source​
Declaration
public int RetryCount { get; set; }

OnPublishedCallback​

View Source​
Declaration
public Action OnPublishedCallback { get; set; }

PublishMessageFilter​

View Source​
Declaration
public Action<string, IBasicProperties, IMessage> PublishMessageFilter { get; set; }

GetMessageFilter​

View Source​
Declaration
public Action<string, BasicGetResult> GetMessageFilter { get; set; }

PrefetchCount​

View Source​
Declaration
public ushort PrefetchCount { get; set; }

Connection​

View Source​
Declaration
public IConnection Connection { get; }

Channel​

View Source​
Declaration
public IModel Channel { get; }

Fields​

Log​

View Source​
Declaration
public static ILog Log

msgFactory​

View Source​
Declaration
protected readonly RabbitMqMessageFactory msgFactory

Methods​

Publish<T>(T)​

View Source​
Declaration
public virtual void Publish<T>(T messageBody)
Parameters​
TypeName
<T>messageBody
Type Parameters​
  • T

Publish<T>(IMessage<T>)​

View Source​
Declaration
public virtual void Publish<T>(IMessage<T> message)
Parameters​
TypeName
ServiceStack.Messaging.IMessage<T>message
Type Parameters​
  • T

Publish(String, IMessage)​

View Source​
Declaration
public virtual void Publish(string queueName, IMessage message)
Parameters​
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage

SendOneWay(Object)​

View Source​
Declaration
public virtual void SendOneWay(object requestDto)
Parameters​
TypeName
System.ObjectrequestDto

SendOneWay(String, Object)​

View Source​
Declaration
public virtual void SendOneWay(string queueName, object requestDto)
Parameters​
TypeName
System.StringqueueName
System.ObjectrequestDto

SendAllOneWay(IEnumerable<Object>)​

View Source​
Declaration
public virtual void SendAllOneWay(IEnumerable<object> requests)
Parameters​
TypeName
System.Collections.Generic.IEnumerable<System.Object>requests

Publish(String, IMessage, String)​

View Source​
Declaration
public virtual void Publish(string queueName, IMessage message, string exchange)
Parameters​
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage
System.Stringexchange

PublishMessage(String, String, IBasicProperties, Byte[])​

View Source​
Declaration
public virtual void PublishMessage(string exchange, string routingKey, IBasicProperties basicProperties, byte[] body)
Parameters​
TypeName
System.Stringexchange
System.StringroutingKey
IBasicPropertiesbasicProperties
System.Byte[]body

GetMessage(String, Boolean)​

View Source​
Declaration
public virtual BasicGetResult GetMessage(string queueName, bool noAck)
Returns​

BasicGetResult

Parameters​
TypeName
System.StringqueueName
System.BooleannoAck

Dispose()​

View Source​
Declaration
public virtual void Dispose()

Implements​