Class SimpleBatchingStrategy
Inheritance
System.Object
SimpleBatchingStrategy
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public class SimpleBatchingStrategy : object, IBatchingStrategy
Constructors
|
Edit this page
View Source
SimpleBatchingStrategy(Int32, Int32, Int64)
Declaration
public SimpleBatchingStrategy(int batchSize, int bufferLimit, long timeout)
Parameters
| Type |
Name |
Description |
| System.Int32 |
batchSize |
|
| System.Int32 |
bufferLimit |
|
| System.Int64 |
timeout |
|
Methods
|
Edit this page
View Source
AddToBatch(String, String, IMessage)
Declaration
public MessageBatch? AddToBatch(string exch, string routKey, IMessage input)
Parameters
| Type |
Name |
Description |
| System.String |
exch |
|
| System.String |
routKey |
|
| IMessage |
input |
|
Returns
|
Edit this page
View Source
CanDebatch(IMessageHeaders)
Declaration
public 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
public void DeBatch(IMessage input, Action<IMessage> fragmentConsumer)
Parameters
| Type |
Name |
Description |
| IMessage |
input |
|
| Action<IMessage> |
fragmentConsumer |
|
|
Edit this page
View Source
NextRelease()
Declaration
public DateTime? NextRelease()
Returns
| Type |
Description |
| System.Nullable<DateTime> |
|
|
Edit this page
View Source
ReleaseBatches()
Declaration
public ICollection<MessageBatch> ReleaseBatches()
Returns
Implements