Package org.axonframework.messaging.core.annotation

Class MessageStreamResolverUtils

java.lang.Object

org.axonframework.messaging.core.annotation.MessageStreamResolverUtils

@Internal
public class MessageStreamResolverUtils
extends Object

Utility class that can resolve the result of any MessageHandler into the expected corresponding MessageStream.

This utility class currently has a major drawback, which is that it only takes the "top level" type into account. Differently put, if we receive a Mono<Message> as the given result of resolveToStream(Object, MessageTypeResolver), we will push that Message through the given typeResolver and make it the Message.payload(). Similarly, if we receive a CompletableFuture<List<Object>> (or CompletableFuture<List<Message>> for that matter), we will return a MessageStream.Single, while we are actually dealing with a MessageStream.

These are known limitation that will be supported in due time.

Since:

5.0.0

Author:

Simon Zambrovski, Steven van Beelen

Method Summary

Modifier and Type	Method	Description
static MessageStream<?>	resolveToStream(Object result, MessageTypeResolver typeResolver)	Resolves the given result into a MessageStream, using the typeResolver when a Message is constructed to define the MessageType.

Methods inherited from class java.lang.Object

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

Method Details

resolveToStream

public static MessageStream<?> resolveToStream(@Nullable
 Object result,
 @Nonnull
 MessageTypeResolver typeResolver)

Resolves the given result into a MessageStream, using the typeResolver when a Message is constructed to define the MessageType.

Is able to switch between Optional, CompletableFuture, Iterable, Stream, Mono, and Flux. If none of the above apply, or the given result is null, MessageStream.just(Message) will be used.

Parameters:

result - The result to map into a MessageStream.

typeResolver - The MessageTypeResolver used to resolve the MessageType for Messages that are held in the returned MessageStream.

Returns:

A MessageStream based on the given result.