Interface IBatchingStrategy

Namespace

Steeltoe.Messaging.RabbitMQ.Batch

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public interface IBatchingStrategy

Methods

AddToBatch(string, string, IMessage)

MessageBatch? AddToBatch(string exchange, string routingKey, IMessage message)

Parameters

exchange string

routingKey string

message IMessage

Returns

MessageBatch?

CanDebatch(IMessageHeaders)

bool CanDebatch(IMessageHeaders properties)

Parameters

properties IMessageHeaders

Returns

bool

DeBatch(IMessage, Action<IMessage>)

void DeBatch(IMessage message, Action<IMessage> fragmentConsumer)

Parameters

message IMessage

fragmentConsumer Action<IMessage>

NextRelease()

DateTime? NextRelease()

Returns

DateTime?

ReleaseBatches()

ICollection<MessageBatch> ReleaseBatches()

Returns

ICollection<MessageBatch>