Uses of Class
io.fluxzero.sdk.common.Message

Packages that use Message

Package	Description
io.fluxzero.sdk.common
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.modeling
io.fluxzero.sdk.publishing
io.fluxzero.sdk.publishing.correlation
io.fluxzero.sdk.publishing.dataprotection
io.fluxzero.sdk.publishing.routing
io.fluxzero.sdk.scheduling
io.fluxzero.sdk.tracking.handling
io.fluxzero.sdk.tracking.handling.authentication
io.fluxzero.sdk.web

Uses of Message in io.fluxzero.sdk.common

Methods in io.fluxzero.sdk.common that return Message

Modifier and Type	Method	Description
Message	Message.addMetadata(Metadata metadata)	Returns a new message with the combined metadata.
Message	Message.addMetadata(Object... keyValues)	Adds multiple metadata entries.
Message	Message.addMetadata(String key, Object value)	Adds a single metadata entry.
Message	Message.addMetadata(Map<String,?> values)	Adds metadata from a given map.
Message	Message.addUser(User user)	Attaches a user object to the metadata using the configured UserProvider.
static Message	Message.asMessage(Object object)	Converts any object into a Message.
Message	HasMessage.toMessage()	Returns the underlying Message representation of this object.
Message	Message.toMessage()
Message	Message.withPayload(Object payload)	Returns a new message instance with the provided payload and existing metadata, ID, and timestamp.

Uses of Message in io.fluxzero.sdk.common.serialization

Methods in io.fluxzero.sdk.common.serialization that return Message

Modifier and Type	Method	Description
Message	DeserializingMessage.toMessage()

Constructors in io.fluxzero.sdk.common.serialization with parameters of type Message

Modifier	Constructor	Description
	DeserializingMessage(@NonNull Message message, MessageType messageType, Serializer serializer)
	DeserializingMessage(@NonNull Message message, MessageType messageType, String topic, Serializer serializer)

Uses of Message in io.fluxzero.sdk.modeling

Methods in io.fluxzero.sdk.modeling that return Message

Modifier and Type	Method	Description
Message	DefaultEntityHelper.MessageWithEntity.toMessage()

Methods in io.fluxzero.sdk.modeling with parameters of type Message

Modifier and Type	Method	Description
Entity<T>	Entity.apply(Message eventMessage)	Applies the given message to the entity.
Entity<T>	ImmutableEntity.apply(Message message)
Entity<T>	LazyAggregateRoot.apply(Message eventMessage)
Entity<T>	ModifiableAggregateRoot.apply(Message message)
protected Entity<T>	ModifiableAggregateRoot.apply(Message message, boolean assertLegal)
Entity<T>	ModifiableEntity.apply(Message eventMessage)
Entity<T>	NoOpEntity.apply(Message eventMessage)
SideEffectFreeEntity<T>	SideEffectFreeEntity.apply(Message eventMessage)

Uses of Message in io.fluxzero.sdk.publishing

Methods in io.fluxzero.sdk.publishing that return Message

Modifier and Type	Method	Description
Message	AdhocDispatchInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts a message before dispatch for the given message type and topic.
Message	DispatchInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts the dispatch of a message before it is serialized and published or locally handled.

Methods in io.fluxzero.sdk.publishing that return types with arguments of type Message

Modifier and Type	Method	Description
protected CompletableFuture<Message>	DefaultGenericGateway.emptyReturnMessage()
CompletableFuture<Message>	CommandGateway.sendForMessage(Message message)	Sends a fully-formed Message and returns a future for the result Message.
default CompletableFuture<Message>	GenericGateway.sendForMessage(Message message)	Sends a single Message and returns a future that resolves to the complete Message response.
CompletableFuture<Message>	QueryGateway.sendForMessage(Message message)	Sends the given Message and returns a future representing the resulting message.
List<CompletableFuture<Message>>	CommandGateway.sendForMessages(Message... messages)	Sends multiple messages and returns futures for the result messages.
List<CompletableFuture<Message>>	DefaultGenericGateway.sendForMessages(Message... messages)
List<CompletableFuture<Message>>	GenericGateway.sendForMessages(Message... messages)	Sends multiple messages and returns futures for their full Message responses.
List<CompletableFuture<Message>>	QueryGateway.sendForMessages(Message... messages)	Sends multiple query Messages and returns a list of futures for the raw responses.

Methods in io.fluxzero.sdk.publishing with parameters of type Message

Modifier and Type	Method	Description
Message	AdhocDispatchInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts a message before dispatch for the given message type and topic.
Message	DispatchInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts the dispatch of a message before it is serialized and published or locally handled.
SerializedMessage	AdhocDispatchInterceptor.modifySerializedMessage(SerializedMessage serializedMessage, Message message, MessageType messageType, String topic)	Optionally modifies the serialized message before dispatch, delegating to any registered ad hoc interceptor for the current thread.
default SerializedMessage	DispatchInterceptor.modifySerializedMessage(SerializedMessage serializedMessage, Message message, MessageType messageType, String topic)	Allows modifications to the serialized representation of the message before it is actually published.
void	AdhocDispatchInterceptor.monitorDispatch(Message message, MessageType messageType, String topic, String namespace)	Optionally monitors a dispatched message using any registered ad hoc interceptor for the current thread.
default void	DispatchInterceptor.monitorDispatch(Message message, MessageType messageType, String topic, String namespace)	Hook to observe the dispatch of a message.
CompletableFuture<Void>	DefaultEventGateway.publish(Message message, Guarantee guarantee)
CompletableFuture<Void>	EventGateway.publish(Message message, Guarantee guarantee)	Publishes the given Message to Fluxzero and/or local handlers.
default <R> CompletableFuture<R>	GenericGateway.send(Message message)	Sends a Message and returns a future that completes with its response payload.
CompletableFuture<Void>	DefaultGenericGateway.sendAndForget(Guarantee guarantee, Message... messages)
CompletableFuture<Void>	DefaultGenericGateway.sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)
CompletableFuture<Void>	GenericGateway.sendAndForget(Guarantee guarantee, Message... messages)	Sends multiple Message objects with a guarantee.
CompletableFuture<Void>	GenericGateway.sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)	Sends multiple Message objects with a guarantee.
default CompletableFuture<Void>	GenericGateway.sendAndForget(Message message, Guarantee guarantee)	Sends a Message asynchronously with a given guarantee.
default <R> R	GenericGateway.sendAndWait(Message message)	Sends a message and blocks for a result with a configurable timeout.
CompletableFuture<Message>	CommandGateway.sendForMessage(Message message)	Sends a fully-formed Message and returns a future for the result Message.
default CompletableFuture<Message>	GenericGateway.sendForMessage(Message message)	Sends a single Message and returns a future that resolves to the complete Message response.
CompletableFuture<Message>	QueryGateway.sendForMessage(Message message)	Sends the given Message and returns a future representing the resulting message.
List<CompletableFuture<Message>>	CommandGateway.sendForMessages(Message... messages)	Sends multiple messages and returns futures for the result messages.
List<CompletableFuture<Message>>	DefaultGenericGateway.sendForMessages(Message... messages)
List<CompletableFuture<Message>>	GenericGateway.sendForMessages(Message... messages)	Sends multiple messages and returns futures for their full Message responses.
List<CompletableFuture<Message>>	QueryGateway.sendForMessages(Message... messages)	Sends multiple query Messages and returns a list of futures for the raw responses.

Uses of Message in io.fluxzero.sdk.publishing.correlation

Methods in io.fluxzero.sdk.publishing.correlation that return Message

Modifier and Type	Method	Description
Message	CorrelatingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)

Methods in io.fluxzero.sdk.publishing.correlation with parameters of type Message

Modifier and Type	Method	Description
Message	CorrelatingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)

Uses of Message in io.fluxzero.sdk.publishing.dataprotection

Methods in io.fluxzero.sdk.publishing.dataprotection that return Message

Modifier and Type	Method	Description
Message	DataProtectionInterceptor.interceptDispatch(Message m, MessageType messageType, String topic)

Methods in io.fluxzero.sdk.publishing.dataprotection with parameters of type Message

Modifier and Type	Method	Description
Message	DataProtectionInterceptor.interceptDispatch(Message m, MessageType messageType, String topic)

Uses of Message in io.fluxzero.sdk.publishing.routing

Methods in io.fluxzero.sdk.publishing.routing that return Message

Modifier and Type	Method	Description
Message	MessageRoutingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Returns the unmodified Message as this interceptor only modifies the serialized form.

Methods in io.fluxzero.sdk.publishing.routing with parameters of type Message

Modifier and Type	Method	Description
Message	MessageRoutingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Returns the unmodified Message as this interceptor only modifies the serialized form.
SerializedMessage	MessageRoutingInterceptor.modifySerializedMessage(SerializedMessage serializedMessage, Message m, MessageType messageType, String topic)	Computes and sets the routing segment on the serialized message if not already present.

Uses of Message in io.fluxzero.sdk.scheduling

Subclasses of Message in io.fluxzero.sdk.scheduling

Modifier and Type	Class	Description
class	Schedule	Represents a scheduled message to be delivered at a specific future time.

Methods in io.fluxzero.sdk.scheduling that return Message

Modifier and Type	Method	Description
Message	SchedulingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)

Methods in io.fluxzero.sdk.scheduling with parameters of type Message

Modifier and Type	Method	Description
Message	SchedulingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)

Uses of Message in io.fluxzero.sdk.tracking.handling

Methods in io.fluxzero.sdk.tracking.handling that return Message

Modifier and Type	Method	Description
Message	DefaultResponseMapper.map(Object response)
Message	DefaultResponseMapper.map(Object response, Metadata metadata)
Message	ResponseMapper.map(Object response)	Maps the given response object to a Message.
Message	ResponseMapper.map(Object response, Metadata metadata)	Maps the given response object and metadata to a Message.

Uses of Message in io.fluxzero.sdk.tracking.handling.authentication

Methods in io.fluxzero.sdk.tracking.handling.authentication that return Message

Modifier and Type	Method	Description
Message	AuthenticatingInterceptor.interceptDispatch(Message m, MessageType messageType, String topic)

Methods in io.fluxzero.sdk.tracking.handling.authentication with parameters of type Message

Modifier and Type	Method	Description
Message	AuthenticatingInterceptor.interceptDispatch(Message m, MessageType messageType, String topic)

Uses of Message in io.fluxzero.sdk.web

Subclasses of Message in io.fluxzero.sdk.web

Modifier and Type	Class	Description
class	WebRequest	Represents a web request message within the Fluxzero Runtime.
class	WebResponse	Represents a response to a WebRequest in the Fluxzero Runtime.

Methods in io.fluxzero.sdk.web that return Message

Modifier and Type	Method	Description
Message	WebResponseCompressingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	No-op for message interception.
Message	WebsocketResponseInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts and conditionally modifies an outgoing message in the context of a WebSocket request.

Methods in io.fluxzero.sdk.web with parameters of type Message

Modifier and Type	Method	Description
Message	WebResponseCompressingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	No-op for message interception.
Message	WebsocketResponseInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)	Intercepts and conditionally modifies an outgoing message in the context of a WebSocket request.
SerializedMessage	WebResponseCompressingInterceptor.modifySerializedMessage(SerializedMessage response, Message message, MessageType type, String topic)	Compresses the given response message using GZIP if the request supports compression and the response meets compression criteria.

Constructors in io.fluxzero.sdk.web with parameters of type Message

Modifier	Constructor	Description
	WebRequest(Message m)	Constructs a new WebRequest instance using the provided Message.
	WebResponse(Message m)	Constructs a new WebResponse instance using the provided Message object.