You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Right now, the AbstractCorrelatingMessageHandler fails like:
Assert.isAssignable(Message.class, commonElementType, () ->
"The expected collection of Messages contains non-Message element: " + commonElementType);
if custom MessageGroupProcessor (which simply can be lambda) returns just a collection of payloads, but not messages.
The DefaultAggregateHeadersFunction can be used in this case to wrap that collection into a single message with grouped headers.
Similar to what happens in the AbstractAggregatingMessageGroupProcessor.