Class SimpleBatchingStrategy

Namespace

Steeltoe.Messaging.RabbitMQ.Batch

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public class SimpleBatchingStrategy : IBatchingStrategy

Inheritance

object

SimpleBatchingStrategy

Implements

IBatchingStrategy

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

SimpleBatchingStrategy(int, int, long)

public SimpleBatchingStrategy(int batchSize, int bufferLimit, long timeout)

Parameters

batchSize int

bufferLimit int

timeout long

Methods

AddToBatch(string, string, IMessage)

public MessageBatch? AddToBatch(string exch, string routKey, IMessage input)

Parameters

exch string

routKey string

input IMessage

Returns

MessageBatch?

CanDebatch(IMessageHeaders)

public bool CanDebatch(IMessageHeaders properties)

Parameters

properties IMessageHeaders

Returns

bool

DeBatch(IMessage, Action<IMessage>)

public void DeBatch(IMessage input, Action<IMessage> fragmentConsumer)

Parameters

input IMessage

fragmentConsumer Action<IMessage>

NextRelease()

public DateTime? NextRelease()

Returns

DateTime?

ReleaseBatches()

public ICollection<MessageBatch> ReleaseBatches()

Returns

ICollection<MessageBatch>