Interface IBatchingStrategy
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public interface IBatchingStrategy
Methods
|
Edit this page
View Source
AddToBatch(String, String, IMessage)
Declaration
MessageBatch? AddToBatch(string exchange, string routingKey, IMessage message)
Parameters
Type |
Name |
Description |
System.String |
exchange |
|
System.String |
routingKey |
|
IMessage |
message |
|
Returns
|
Edit this page
View Source
CanDebatch(IMessageHeaders)
Declaration
bool CanDebatch(IMessageHeaders properties)
Parameters
Type |
Name |
Description |
IMessageHeaders |
properties |
|
Returns
Type |
Description |
System.Boolean |
|
|
Edit this page
View Source
DeBatch(IMessage, Action<IMessage>)
Declaration
void DeBatch(IMessage message, Action<IMessage> fragmentConsumer)
Parameters
Type |
Name |
Description |
IMessage |
message |
|
Action<IMessage> |
fragmentConsumer |
|
|
Edit this page
View Source
NextRelease()
Declaration
Returns
Type |
Description |
System.Nullable<DateTime> |
|
|
Edit this page
View Source
ReleaseBatches()
Declaration
ICollection<MessageBatch> ReleaseBatches()
Returns