Class StandardBatchUtils

java.lang.Object

org.springframework.cloud.stream.function.StandardBatchUtils

public final class StandardBatchUtils
extends Object

Since:

4.2

Author:

Oleg Zhurakousky

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StandardBatchUtils.BatchMessageBuilder

Method Summary

Modifier and Type	Method	Description
static Map.Entry<Object, Map<String,Object>>	getMessageByIndex(org.springframework.messaging.Message<List<Object>> batchMessage, int index)	Extracts individual Message by index from batch Message.
static Iterable<Map.Entry<Object, Map<String,Object>>>	iterate(org.springframework.messaging.Message<List<Object>> batchMessage)	Iterates over batch message structure returning Iterable of individual messages.

Methods inherited from class Object

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

Method Details

iterate

public static Iterable<Map.Entry<Object, Map<String,Object>>> iterate(org.springframework.messaging.Message<List<Object>> batchMessage)

Iterates over batch message structure returning Iterable of individual messages.

Parameters:

batchMessage - instance of batch Message

Returns:

instance of Iterable representing individual Messages in a batch Message as Map.Entry.

getMessageByIndex

public static Map.Entry<Object, Map<String,Object>> getMessageByIndex(org.springframework.messaging.Message<List<Object>> batchMessage,
 int index)

Extracts individual Message by index from batch Message.

Parameters:

batchMessage - instance of batch Message

index - index of individual Message in a batch

Returns:

individual Message in a batch Message