Class RabbitMessageSource

Namespace

Steeltoe.Integration.Rabbit.Inbound

Assembly

Steeltoe.Integration.RabbitMQ.dll

public class RabbitMessageSource : AbstractMessageSource<object>, IMessageSource<object>, IMessageSource

Inheritance

object

AbstractExpressionEvaluator

AbstractMessageSource<object>

RabbitMessageSource

Implements

IMessageSource<object>

IMessageSource

Inherited Members

AbstractMessageSource<object>.HeaderExpressions

AbstractMessageSource<object>.Receive()

AbstractMessageSource<object>.BuildMessage(object)

AbstractExpressionEvaluator.ExpressionParser

AbstractExpressionEvaluator.EvaluationContext

AbstractExpressionEvaluator.IntegrationServices

AbstractExpressionEvaluator.MessageBuilderFactory

AbstractExpressionEvaluator.TypeConverter

AbstractExpressionEvaluator.ApplicationContext

AbstractExpressionEvaluator.GetMessageBuilderFactory()

AbstractExpressionEvaluator.GetEvaluationContext(bool)

AbstractExpressionEvaluator.EvaluateExpression<T>(IExpression, IMessage)

AbstractExpressionEvaluator.EvaluateExpression(IExpression, IMessage, Type)

AbstractExpressionEvaluator.EvaluateExpression(string, object)

AbstractExpressionEvaluator.EvaluateExpression(string, object, Type)

AbstractExpressionEvaluator.EvaluateExpression(IExpression)

AbstractExpressionEvaluator.EvaluateExpression(IExpression, object, Type)

AbstractExpressionEvaluator.EvaluateExpression<T>(IExpression, object)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RabbitMessageSource(IApplicationContext, IConnectionFactory, RabbitAckCallbackFactory, string)

public RabbitMessageSource(IApplicationContext context, IConnectionFactory connectionFactory, RabbitMessageSource.RabbitAckCallbackFactory ackCallbackFactory, string queueName)

Parameters

context IApplicationContext

connectionFactory IConnectionFactory

ackCallbackFactory RabbitMessageSource.RabbitAckCallbackFactory

queueName string

RabbitMessageSource(IApplicationContext, IConnectionFactory, string)

public RabbitMessageSource(IApplicationContext context, IConnectionFactory connectionFactory, string queueName)

Parameters

context IApplicationContext

connectionFactory IConnectionFactory

queueName string

Properties

AckCallbackFactory

public RabbitMessageSource.RabbitAckCallbackFactory AckCallbackFactory { get; }

Property Value

RabbitMessageSource.RabbitAckCallbackFactory

BatchingStrategy

public IBatchingStrategy BatchingStrategy { get; set; }

Property Value

IBatchingStrategy

ConnectionFactory

public IConnectionFactory ConnectionFactory { get; }

Property Value

IConnectionFactory

MessageConverter

public ISmartMessageConverter MessageConverter { get; set; }

Property Value

ISmartMessageConverter

MessageHeaderConverter

public IMessageHeadersConverter MessageHeaderConverter { get; set; }

Property Value

IMessageHeadersConverter

QueueName

public string QueueName { get; }

Property Value

string

RawMessageHeader

public bool RawMessageHeader { get; set; }

Property Value

bool

Transacted

public bool Transacted { get; set; }

Property Value

bool

Methods

DoReceive()

protected override object DoReceive()

Returns

object