Package org.springframework.cloud.stream.binder

Class PartitionTestSupport

java.lang.Object

org.springframework.cloud.stream.binder.PartitionTestSupport

All Implemented Interfaces:

org.springframework.cloud.stream.binder.PartitionKeyExtractorStrategy, org.springframework.cloud.stream.binder.PartitionSelectorStrategy

public class PartitionTestSupport
extends Object
implements org.springframework.cloud.stream.binder.PartitionKeyExtractorStrategy, org.springframework.cloud.stream.binder.PartitionSelectorStrategy

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
PartitionTestSupport()

Method Summary

Modifier and Type	Method	Description
Object	extractKey(org.springframework.messaging.Message<?> message)
int	selectPartition(Object key, int divisor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionTestSupport

public PartitionTestSupport()

Method Details

selectPartition

public int selectPartition(Object key,
 int divisor)

Specified by:

selectPartition in interface org.springframework.cloud.stream.binder.PartitionSelectorStrategy

extractKey

public Object extractKey(org.springframework.messaging.Message<?> message)

Specified by:

extractKey in interface org.springframework.cloud.stream.binder.PartitionKeyExtractorStrategy