Uses of Enum Class
io.fluxzero.common.MessageType

Packages that use MessageType

Package	Description
io.fluxzero.common
io.fluxzero.common.api.tracking
io.fluxzero.common.tracking
io.fluxzero.sdk
io.fluxzero.sdk.common
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.common.websocket
io.fluxzero.sdk.configuration
io.fluxzero.sdk.configuration.client
io.fluxzero.sdk.publishing
io.fluxzero.sdk.publishing.client
io.fluxzero.sdk.publishing.correlation
io.fluxzero.sdk.publishing.dataprotection
io.fluxzero.sdk.publishing.routing
io.fluxzero.sdk.scheduling
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.tracking.handling
io.fluxzero.sdk.tracking.handling.authentication
io.fluxzero.sdk.web
io.fluxzero.testserver.websocket

Uses of MessageType in io.fluxzero.common

Subclasses with type arguments of type MessageType in io.fluxzero.common

Modifier and Type	Class	Description
enum	MessageType	Enumerates the types of messages recognized and routed by the Fluxzero Runtime.

Methods in io.fluxzero.common that return MessageType

Modifier and Type	Method	Description
static MessageType	MessageType.valueOf(String name)	Returns the enum constant of this class with the specified name.
static MessageType[]	MessageType.values()	Returns an array containing the constants of this enum class, in the order they are declared.

Methods in io.fluxzero.common with parameters of type MessageType

Modifier and Type	Method	Description
static String	ServicePathBuilder.gatewayPath(MessageType messageType)	Returns the gateway path used to publish messages of the given MessageType.
static String	ServicePathBuilder.trackingPath(MessageType messageType)	Returns the tracking path used to read (track) messages of the given MessageType.

Uses of MessageType in io.fluxzero.common.api.tracking

Methods in io.fluxzero.common.api.tracking with parameters of type MessageType

Modifier and Type	Method	Description
static StorePosition	StorePosition.fromJson(MessageType messageType, String consumer, int[] segment, long lastIndex, Guarantee guarantee)

Constructors in io.fluxzero.common.api.tracking with parameters of type MessageType

Modifier	Constructor	Description
	ClaimSegment(MessageType messageType, String consumer, String trackerId, long maxTimeout, boolean clientControlledIndex, String typeFilter, boolean filterMessageTarget, Long lastIndex, Long purgeTimeout)

Uses of MessageType in io.fluxzero.common.tracking

Constructors in io.fluxzero.common.tracking with parameters of type MessageType

Modifier	Constructor	Description
	WebSocketTracker(Read read, MessageType messageType, String clientId, String sessionId, Consumer<MessageBatch> handler)

Uses of MessageType in io.fluxzero.sdk

Methods in io.fluxzero.sdk with parameters of type MessageType

Modifier and Type	Method	Description
Tracking	Fluxzero.tracking(MessageType messageType)	Returns a client to assist with the tracking of a given message type.

Uses of MessageType in io.fluxzero.sdk.common

Methods in io.fluxzero.sdk.common with parameters of type MessageType

Modifier and Type	Method	Description
static Set<String>	ClientUtils.getTopics(MessageType messageType, Object handler)	Extracts all topics associated with the given handler object and message type.
static Set<String>	ClientUtils.getTopics(MessageType messageType, Collection<Class<?>> handlerClasses)	Extracts all topics from HandleDocument or HandleCustom annotated methods for the given classes.

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

Methods in io.fluxzero.sdk.common.serialization with parameters of type MessageType

Modifier and Type	Method	Description
default DeserializingMessage	Serializer.deserializeMessage(SerializedMessage message, MessageType messageType)	Deserializes a single SerializedMessage into a DeserializingMessage.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType, UnknownTypeStrategy unknownTypeStrategy)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType, String topic)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.
default Stream<DeserializingMessage>	Serializer.deserializeMessages(Stream<SerializedMessage> dataStream, MessageType messageType, String topic, UnknownTypeStrategy unknownTypeStrategy)	Deserializes a stream of SerializedMessage into DeserializingMessage instances with the specified MessageType.

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

Modifier	Constructor	Description
	DeserializingMessage(SerializedMessage message, Function<Type,Object> payload, MessageType messageType, String topic, Serializer serializer)
	DeserializingMessage(@NonNull Message message, MessageType messageType, Serializer serializer)
	DeserializingMessage(@NonNull Message message, MessageType messageType, String topic, Serializer serializer)
	DeserializingMessage(DeserializingObject<byte[], SerializedMessage> delegate, MessageType messageType, String topic, Serializer serializer)

Uses of MessageType in io.fluxzero.sdk.common.websocket

Methods in io.fluxzero.sdk.common.websocket with parameters of type MessageType

Modifier and Type	Method	Description
static String	ServiceUrlBuilder.gatewayUrl(MessageType messageType, String topic, WebSocketClient.ClientConfig clientConfig)	Builds the URL to send messages to a gateway endpoint for the specified message type and topic.
static String	ServiceUrlBuilder.trackingUrl(MessageType messageType, String topic, WebSocketClient.ClientConfig clientConfig)	Builds the URL to subscribe to messages from a tracking endpoint for the specified message type and topic.

Uses of MessageType in io.fluxzero.sdk.configuration

Methods in io.fluxzero.sdk.configuration that return types with arguments of type MessageType

Modifier and Type	Method	Description
Map<MessageType, List<ConsumerConfiguration>>	FluxzeroConfiguration.customConsumerConfigurations()	Provides custom consumer configurations per message type.
Map<MessageType, ConsumerConfiguration>	FluxzeroConfiguration.defaultConsumerConfigurations()	Provides the default consumer configuration per message type.
Map<MessageType, List<BatchInterceptor>>	FluxzeroConfiguration.generalBatchInterceptors()	Interceptors applied to message batches during tracking and dispatch.
Map<MessageType, List<DispatchInterceptor>>	FluxzeroConfiguration.highPrioDispatchInterceptors()	Dispatch interceptors applied before low-priority interceptors.
Map<MessageType, List<HandlerDecorator>>	FluxzeroConfiguration.highPrioHandlerDecorators()	Decorators applied to handlers before low-priority decorators.
Map<MessageType, List<DispatchInterceptor>>	FluxzeroConfiguration.lowPrioDispatchInterceptors()	Dispatch interceptors applied after high-priority interceptors.
Map<MessageType, List<HandlerDecorator>>	FluxzeroConfiguration.lowPrioHandlerDecorators()	Decorators applied to handlers after high-priority decorators.

Methods in io.fluxzero.sdk.configuration with parameters of type MessageType

Modifier and Type	Method	Description
FluxzeroBuilder	DefaultFluxzero.Builder.addBatchInterceptor(BatchInterceptor interceptor, MessageType... forTypes)
FluxzeroBuilder	FluxzeroBuilder.addBatchInterceptor(BatchInterceptor interceptor, MessageType... forTypes)	Registers a BatchInterceptor that applies to the given message types.
DefaultFluxzero.Builder	DefaultFluxzero.Builder.addConsumerConfiguration(@NonNull ConsumerConfiguration configuration, MessageType... messageTypes)
FluxzeroBuilder	FluxzeroBuilder.addConsumerConfiguration(ConsumerConfiguration consumerConfiguration, MessageType... messageTypes)	Adds a specific consumer configuration for one or more message types.
DefaultFluxzero.Builder	DefaultFluxzero.Builder.addDispatchInterceptor(@NonNull DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes)
FluxzeroBuilder	FluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes)	Adds a DispatchInterceptor for specified message types with optional priority.
default FluxzeroBuilder	FluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, MessageType... forTypes)	Adds a DispatchInterceptor that modifies or monitors message dispatch.
DefaultFluxzero.Builder	DefaultFluxzero.Builder.addHandlerDecorator(@NonNull HandlerDecorator interceptor, boolean highPriority, MessageType... forTypes)
FluxzeroBuilder	FluxzeroBuilder.addHandlerDecorator(HandlerDecorator decorator, boolean highPriority, MessageType... forTypes)	Adds a HandlerDecorator with control over priority.
default FluxzeroBuilder	FluxzeroBuilder.addHandlerDecorator(HandlerDecorator decorator, MessageType... forTypes)	Adds a HandlerDecorator for the given message types.
default FluxzeroBuilder	FluxzeroBuilder.addHandlerInterceptor(HandlerInterceptor interceptor, boolean highPriority, MessageType... forTypes)	Adds a HandlerInterceptor with specified priority.
default FluxzeroBuilder	FluxzeroBuilder.addHandlerInterceptor(HandlerInterceptor interceptor, MessageType... forTypes)	Adds a HandlerInterceptor for given message types.
DefaultFluxzero.Builder	DefaultFluxzero.Builder.configureDefaultConsumer(@NonNull MessageType messageType, @NonNull UnaryOperator<ConsumerConfiguration> updateFunction)
FluxzeroBuilder	FluxzeroBuilder.configureDefaultConsumer(MessageType messageType, UnaryOperator<ConsumerConfiguration> updateFunction)	Update the default consumer configuration for the specified message type.
protected GenericGateway	DefaultFluxzero.Builder.createRequestGateway(Client client, MessageType messageType, String topic, RequestHandler requestHandler, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper)
protected ConsumerConfiguration	DefaultFluxzero.Builder.getDefaultConsumerConfiguration(MessageType messageType)
protected HandlerRegistry	DefaultFluxzero.Builder.localHandlerRegistry(MessageType messageType, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)
protected MethodInvocationValidator<? super DeserializingMessage>	DefaultFluxzero.Builder.methodInvocationValidator(MessageType messageType)
Tracking	DefaultFluxzero.tracking(MessageType messageType)

Method parameters in io.fluxzero.sdk.configuration with type arguments of type MessageType

Modifier and Type	Method	Description
protected GenericGateway	DefaultFluxzero.Builder.createRequestGateway(Client client, MessageType messageType, String topic, RequestHandler requestHandler, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper)
protected Fluxzero	DefaultFluxzero.Builder.doBuild(Map<MessageType, ? extends Tracking> trackingSupplier, Function<String, ? extends GenericGateway> customGatewaySupplier, CommandGateway commandGateway, QueryGateway queryGateway, EventGateway eventGateway, ResultGateway resultGateway, ErrorGateway errorGateway, MetricsGateway metricsGateway, WebRequestGateway webRequestGateway, AggregateRepository aggregateRepository, SnapshotStore snapshotStore, EventStore eventStore, KeyValueStore keyValueStore, DocumentStore documentStore, MessageScheduler messageScheduler, UserProvider userProvider, Cache cache, Serializer serializer, CorrelationDataProvider correlationDataProvider, IdentityProvider identityProvider, PropertySource propertySource, DelegatingClock clock, TaskScheduler taskScheduler, Client client, ThrowingRunnable shutdownHandler)
protected HandlerRegistry	DefaultFluxzero.Builder.localHandlerRegistry(MessageType messageType, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)

Uses of MessageType in io.fluxzero.sdk.configuration.client

Methods in io.fluxzero.sdk.configuration.client with parameters of type MessageType

Modifier and Type	Method	Description
void	ClientDispatchMonitor.accept(MessageType messageType, String topic, String namespace, List<SerializedMessage> messages)	Called when a batch of messages is dispatched by the client.
protected abstract GatewayClient	AbstractClient.createGatewayClient(MessageType messageType, String topic)	Subclasses must implement this method to return a GatewayClient for the given message type and topic.
protected GatewayClient	LocalClient.createGatewayClient(MessageType messageType, String topic)
protected GatewayClient	WebSocketClient.createGatewayClient(MessageType messageType, String topic)
protected abstract TrackingClient	AbstractClient.createTrackingClient(MessageType messageType, String topic)	Subclasses must implement this method to return a TrackingClient for the given message type and topic.
protected TrackingClient	LocalClient.createTrackingClient(MessageType messageType, String topic)
protected TrackingClient	WebSocketClient.createTrackingClient(MessageType messageType, String topic)
GatewayClient	AbstractClient.getGatewayClient(MessageType messageType, String topic)	Returns the memoized GatewayClient for the given message type and topic.
default GatewayClient	Client.getGatewayClient(MessageType messageType)	Returns a GatewayClient for the given message type using the default topic (typically null).
GatewayClient	Client.getGatewayClient(MessageType messageType, String topic)	Returns a GatewayClient for the given message type and topic.
TrackingClient	AbstractClient.getTrackingClient(MessageType messageType, String topic)
default TrackingClient	Client.getTrackingClient(MessageType messageType)	Returns a TrackingClient for the given message type using the default topic.
TrackingClient	Client.getTrackingClient(MessageType messageType, String topic)	Returns a TrackingClient for the given message type and topic.
Registration	AbstractClient.monitorDispatch(ClientDispatchMonitor monitor, MessageType... messageTypes)
Registration	Client.monitorDispatch(ClientDispatchMonitor monitor, MessageType... messageTypes)	Registers a ClientDispatchMonitor to receive hooks and diagnostics when messages of the given MessageTypes are dispatched from this client.
WebSocketClient.ClientConfig	WebSocketClient.ClientConfig.withGatewaySessions(MessageType messageType, int count)	Returns a new ClientConfig with a modified gateway session count for the specified message type.
WebSocketClient.ClientConfig	WebSocketClient.ClientConfig.withTrackingConfig(MessageType messageType, WebSocketClient.TrackingClientConfig trackingConfig)	Returns a new ClientConfig with a modified tracking config for the specified message type.

Uses of MessageType in io.fluxzero.sdk.publishing

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

Modifier and Type	Method	Description
static Optional<? extends DispatchInterceptor>	AdhocDispatchInterceptor.getAdhocInterceptor(MessageType messageType)	Returns the current thread-local ad hoc interceptor for the given MessageType, if present.
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.
static void	AdhocDispatchInterceptor.runWithAdhocInterceptor(Runnable task, DispatchInterceptor adhocInterceptor, MessageType... messageTypes)	Executes the given Runnable while temporarily enabling the provided interceptor for the specified message types.
static <T> T	AdhocDispatchInterceptor.runWithAdhocInterceptor(Callable<T> task, DispatchInterceptor adhocInterceptor, MessageType... messageTypes)	Executes the given Callable while temporarily enabling the provided interceptor for the specified message types.

Constructors in io.fluxzero.sdk.publishing with parameters of type MessageType

Modifier	Constructor	Description
	DefaultRequestHandler(Client client, MessageType resultType)	Constructs a DefaultRequestHandler with the specified client and message type, and a default timeout of 200 seconds.

Uses of MessageType in io.fluxzero.sdk.publishing.client

Constructors in io.fluxzero.sdk.publishing.client with parameters of type MessageType

Modifier	Constructor	Description
	WebsocketGatewayClient(String endPointUrl, WebSocketClient client, MessageType type, String topic)	Constructs a new WebsocketGatewayClient instance using the specified parameters.
	WebsocketGatewayClient(URI endPointUri, WebSocketClient client, MessageType type, String topic, boolean sendMetrics)	Constructs a new WebsocketGatewayClient instance using the specified parameters.

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

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

Modifier and Type	Method	Description
default Map<String,String>	CorrelationDataProvider.getCorrelationData(Client client, SerializedMessage currentMessage, MessageType messageType)	Returns correlation metadata derived from a serialized message and optional context.
Message	CorrelatingInterceptor.interceptDispatch(Message message, MessageType messageType, String topic)

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

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

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

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

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

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 MessageType in io.fluxzero.sdk.scheduling

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

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

Uses of MessageType in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client that return MessageType

Modifier and Type	Method	Description
MessageType	CachingTrackingClient.getMessageType()
MessageType	TrackingClient.getMessageType()	Returns the MessageType (e.g., COMMAND, EVENT, QUERY) associated with this tracking client.

Methods in io.fluxzero.sdk.tracking.client with parameters of type MessageType

Modifier and Type	Method	Description
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Client client)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Client client)	Starts one or more trackers.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.

Constructors in io.fluxzero.sdk.tracking.client with parameters of type MessageType

Modifier	Constructor	Description
	InMemoryMessageStore(MessageType messageType)
	LocalTrackingClient(MessageType messageType, String topic, Duration messageExpiration)
	LocalTrackingClient(MessageStore messageStore, MessageType messageType)
	LocalTrackingClient(MessageStore messageStore, MessageType messageType, String topic)
	WebsocketTrackingClient(String endPointUrl, WebSocketClient client, MessageType type, String topic)
	WebsocketTrackingClient(URI endPointUri, WebSocketClient client, MessageType type, String topic, boolean sendMetrics)

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

Methods in io.fluxzero.sdk.tracking.handling that return types with arguments of type MessageType

Modifier and Type	Method	Description
protected Optional<MessageType>	TriggerParameterResolver.getTriggerMessageType(HasMessage message)

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

Modifier and Type	Method	Description
protected Class<? extends Annotation>	DefaultHandlerFactory.getHandlerAnnotation(MessageType messageType)
protected Optional<DeserializingMessage>	TriggerParameterResolver.getTriggerMessage(long index, Class<?> type, MessageType messageType)

Constructors in io.fluxzero.sdk.tracking.handling with parameters of type MessageType

Modifier	Constructor	Description
	DefaultHandlerFactory(MessageType messageType, HandlerDecorator defaultDecorator, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, MethodInvocationValidator<? super DeserializingMessage> methodInvocationValidator, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)
	DefaultHandlerFactory(MessageType messageType, HandlerDecorator defaultDecorator, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)

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

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

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

Uses of MessageType in io.fluxzero.sdk.web

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

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.

Uses of MessageType in io.fluxzero.testserver.websocket

Constructors in io.fluxzero.testserver.websocket with parameters of type MessageType

Modifier	Constructor	Description
	ConsumerEndpoint(MessageStore messageStore, MessageType messageType)