Class RabbitMessageSource
Inheritance
System.Object
RabbitMessageSource
Assembly: Steeltoe.Integration.RabbitMQ.dll
Syntax
public class RabbitMessageSource : AbstractMessageSource<object>
Constructors
|
Edit this page
View Source
RabbitMessageSource(IApplicationContext, IConnectionFactory, RabbitMessageSource.RabbitAckCallbackFactory, String)
Declaration
public RabbitMessageSource(IApplicationContext context, IConnectionFactory connectionFactory, RabbitMessageSource.RabbitAckCallbackFactory ackCallbackFactory, string queueName)
Parameters
|
Edit this page
View Source
RabbitMessageSource(IApplicationContext, IConnectionFactory, String)
Declaration
public RabbitMessageSource(IApplicationContext context, IConnectionFactory connectionFactory, string queueName)
Parameters
Type |
Name |
Description |
IApplicationContext |
context |
|
IConnectionFactory |
connectionFactory |
|
System.String |
queueName |
|
Properties
|
Edit this page
View Source
AckCallbackFactory
Declaration
public RabbitMessageSource.RabbitAckCallbackFactory AckCallbackFactory { get; }
Property Value
|
Edit this page
View Source
BatchingStrategy
Declaration
public IBatchingStrategy BatchingStrategy { get; set; }
Property Value
|
Edit this page
View Source
ConnectionFactory
Declaration
public IConnectionFactory ConnectionFactory { get; }
Property Value
|
Edit this page
View Source
MessageConverter
Declaration
public ISmartMessageConverter MessageConverter { get; set; }
Property Value
Type |
Description |
ISmartMessageConverter |
|
|
Edit this page
View Source
Declaration
public IMessageHeadersConverter MessageHeaderConverter { get; set; }
Property Value
|
Edit this page
View Source
QueueName
Declaration
public string QueueName { get; }
Property Value
Type |
Description |
System.String |
|
|
Edit this page
View Source
Declaration
public bool RawMessageHeader { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
Transacted
Declaration
public bool Transacted { get; set; }
Property Value
Type |
Description |
System.Boolean |
|
Methods
|
Edit this page
View Source
DoReceive()
Declaration
protected override object DoReceive()
Returns
Type |
Description |
System.Object |
|
Overrides
Steeltoe.Integration.Endpoint.AbstractMessageSource<System.Object>.DoReceive()
Implements