Class PartitionHandler

Namespace

Steeltoe.Stream.Binder

Assembly

Steeltoe.Stream.StreamBase.dll

public class PartitionHandler

Inheritance

object

PartitionHandler

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PartitionHandler(IExpressionParser, IEvaluationContext, IProducerOptions, IPartitionKeyExtractorStrategy, IPartitionSelectorStrategy)

public PartitionHandler(IExpressionParser expressionParser, IEvaluationContext evaluationContext, IProducerOptions options, IPartitionKeyExtractorStrategy partitionKeyExtractorStrategy, IPartitionSelectorStrategy partitionSelectorStrategy)

Parameters

expressionParser IExpressionParser

evaluationContext IEvaluationContext

options IProducerOptions

partitionKeyExtractorStrategy IPartitionKeyExtractorStrategy

partitionSelectorStrategy IPartitionSelectorStrategy

Properties

PartitionCount

public int PartitionCount { get; set; }

Property Value

int

Methods

DeterminePartition(IMessage)

public int DeterminePartition(IMessage message)

Parameters

message IMessage

Returns

int