org.adroitlogic.ultraesb.api.helper

Interface SplitGroupingCriteria<T>

public interface SplitGroupingCriteria<T>

An interface that lets users define a criteria for split grouping, while the path can split the message into n number of sub messages, you might want to re-group the splitted parts based on some criteria where the grouped split will be sent to a given address. This is very useful in sharding where the split itself contains some information on the shard to which it is targeted and there can be more than one split targeting the same shard. So it is a waste to send different splits to the same shard in different wire-level messages. The grouping criteria lets you re-group the split into lessor number of batches based on the key generated by the calculate(Object) method.

Further to that the same key could be used to obtain the endpoint to send the re-grouped message.

Since:

2.1.0

Author:

Ruwan

See Also:

JSONSupport.splitAndProcess(org.adroitlogic.ultraesb.api.Message, String, String, boolean, SplitGroupingCriteria, long, boolean)

Method Summary

Methods

Modifier and Type	Method and Description
String	calculate(T type) Calculates a unique key that identifies the group to which a given split belongs to.

Method Detail

calculate

String calculate(T type)

Calculates a unique key that identifies the group to which a given split belongs to. Splits having the same key will be grouped to process as a single message.

Parameters:

type - the type of the input object that is expected

Returns:

the group key representing the given split of the given type