Uses of Class
io.fluxzero.common.api.SerializedMessage

Packages that use SerializedMessage

Package	Description
io.fluxzero.common.api
io.fluxzero.common.api.tracking
io.fluxzero.common.tracking
io.fluxzero.proxy
io.fluxzero.sdk.common
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.configuration.client
io.fluxzero.sdk.persisting.eventsourcing.client
io.fluxzero.sdk.persisting.repository
io.fluxzero.sdk.persisting.search.client
io.fluxzero.sdk.publishing
io.fluxzero.sdk.publishing.client
io.fluxzero.sdk.publishing.correlation
io.fluxzero.sdk.publishing.routing
io.fluxzero.sdk.scheduling.client
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.web
io.fluxzero.testserver.scheduling

Uses of SerializedMessage in io.fluxzero.common.api

Methods in io.fluxzero.common.api that return SerializedMessage

Modifier and Type	Method	Description
SerializedMessage	SerializedMessage.withData(@NonNull Data<byte[]> data)

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

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

Modifier and Type	Method	Description
boolean	Position.isNewMessage(SerializedMessage message)

Uses of SerializedMessage in io.fluxzero.common.tracking

Subinterfaces with type arguments of type SerializedMessage in io.fluxzero.common.tracking

Modifier and Type	Interface	Description
interface	MessageStore	A low-level store for serialized messages.

Methods in io.fluxzero.common.tracking that return SerializedMessage

Modifier and Type	Method	Description
protected SerializedMessage	DefaultTrackingStrategy.ensureMessageSegment(SerializedMessage message)

Methods in io.fluxzero.common.tracking that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected List<SerializedMessage>	DefaultTrackingStrategy.getBatch(int[] segment, Position position, int batchSize)
default List<SerializedMessage>	MessageStore.getBatch(Long lastIndex, int maxSize)	Retrieves a batch of messages starting from the given lastIndex (exclusive).
List<SerializedMessage>	MessageStore.getBatch(Long minIndex, int maxSize, boolean inclusive)	Retrieves a batch of messages starting from the given minIndex.

Methods in io.fluxzero.common.tracking with parameters of type SerializedMessage

Modifier and Type	Method	Description
default CompletableFuture<Void>	MessageStore.append(SerializedMessage... messages)	Appends the given messages to the store.
default boolean	Tracker.canHandle(SerializedMessage message, int[] segmentRange)	Checks if the given message can be handled by this tracker based on segment range and type filtering.
protected SerializedMessage	DefaultTrackingStrategy.ensureMessageSegment(SerializedMessage message)

Method parameters in io.fluxzero.common.tracking with type arguments of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	MessageStore.append(List<SerializedMessage> messages)	Appends a list of messages to the store.
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected void	DefaultTrackingStrategy.onUpdate(List<SerializedMessage> messages)

Uses of SerializedMessage in io.fluxzero.proxy

Classes in io.fluxzero.proxy that implement interfaces with type arguments of type SerializedMessage

Modifier and Type	Class	Description
class	ForwardProxyConsumer

Methods in io.fluxzero.proxy with parameters of type SerializedMessage

Modifier and Type	Method	Description
protected HttpRequest	ForwardProxyConsumer.asHttpRequest(SerializedMessage request, URI uri, WebRequestSettings settings)
protected String	ForwardProxyConsumer.formatType(SerializedMessage request)
protected HttpRequest.BodyPublisher	ForwardProxyConsumer.getBodyPublisher(SerializedMessage request)
protected WebRequestSettings	ForwardProxyConsumer.getSettings(SerializedMessage request)
protected void	ForwardProxyConsumer.handle(SerializedMessage request, URI uri, WebRequestSettings settings)
protected void	ProxyRequestHandler.handleResponse(SerializedMessage responseMessage, WebRequest webRequest, io.undertow.server.HttpServerExchange se)
protected io.undertow.server.HttpServerExchange	ProxyRequestHandler.prepareForSending(SerializedMessage responseMessage, io.undertow.server.HttpServerExchange se, int statusCode)
protected void	ForwardProxyConsumer.publishHandleMessageMetrics(SerializedMessage request, boolean exceptionalResult, Instant start)
protected void	ForwardProxyConsumer.sendResponse(WebResponse response, SerializedMessage request)
protected void	ProxyRequestHandler.sendResponse(SerializedMessage responseMessage, io.undertow.server.HttpServerExchange se)

Method parameters in io.fluxzero.proxy with type arguments of type SerializedMessage

Modifier and Type	Method	Description
void	ForwardProxyConsumer.accept(List<SerializedMessage> serializedMessages)
protected void	WebsocketEndpoint.handleDisconnects(List<SerializedMessage> resultMessages)
protected void	WebsocketEndpoint.handleResultMessages(List<SerializedMessage> resultMessages)

Uses of SerializedMessage in io.fluxzero.sdk.common

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

Modifier and Type	Method	Description
SerializedMessage	Message.serialize(Serializer serializer)	Serializes this message to a SerializedMessage using the provided Serializer.

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

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

Modifier and Type	Method	Description
SerializedMessage	DeserializingMessage.getSerializedObject()

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

Modifier and Type	Method	Description
default DeserializingMessage	Serializer.deserializeMessage(SerializedMessage message, MessageType messageType)	Deserializes a single SerializedMessage into a DeserializingMessage.

Method parameters in io.fluxzero.sdk.common.serialization with type arguments of type SerializedMessage

Modifier and Type	Method	Description
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 SerializedMessage

Modifier	Constructor	Description
	DeserializingMessage(SerializedMessage message, Function<Type,Object> payload, MessageType messageType, String topic, Serializer serializer)

Constructor parameters in io.fluxzero.sdk.common.serialization with type arguments of type SerializedMessage

Modifier	Constructor	Description
	DeserializingMessage(DeserializingObject<byte[], SerializedMessage> delegate, MessageType messageType, String topic, Serializer serializer)

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

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

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.

Uses of SerializedMessage in io.fluxzero.sdk.persisting.eventsourcing.client

Methods in io.fluxzero.sdk.persisting.eventsourcing.client that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
default AggregateEventStream<SerializedMessage>	EventStoreClient.getEvents(String aggregateId)	Retrieves the full event stream for a given aggregate.
default AggregateEventStream<SerializedMessage>	EventStoreClient.getEvents(String aggregateId, long lastSequenceNumber)	Retrieves the event stream for an aggregate starting after the given sequence number.
AggregateEventStream<SerializedMessage>	EventStoreClient.getEvents(String aggregateId, long lastSequenceNumber, int maxSize)	Retrieves the event stream for an aggregate with control over size and offset.
AggregateEventStream<SerializedMessage>	InMemoryEventStore.getEvents(String aggregateId, long lastSequenceNumber, int maxSize)
AggregateEventStream<SerializedMessage>	WebSocketEventStoreClient.getEvents(String aggregateId, long lastSequenceNumber, int maxSize)	Retrieves events for a specific aggregate starting after a given sequence number, optionally limiting the result size.

Method parameters in io.fluxzero.sdk.persisting.eventsourcing.client with type arguments of type SerializedMessage

Modifier and Type	Method	Description
default CompletableFuture<Void>	EventStoreClient.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly)	Stores a list of serialized events for a given aggregate identifier.
CompletableFuture<Void>	EventStoreClient.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly, Guarantee guarantee)	Stores events for a given aggregate with an explicit guarantee.
CompletableFuture<Void>	InMemoryEventStore.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly, Guarantee guarantee)
CompletableFuture<Void>	WebSocketEventStoreClient.storeEvents(String aggregateId, List<SerializedMessage> events, boolean storeOnly, Guarantee guarantee)	Stores events for a specific aggregate, with control over store-only mode and delivery guarantee.

Uses of SerializedMessage in io.fluxzero.sdk.persisting.repository

Method parameters in io.fluxzero.sdk.persisting.repository with type arguments of type SerializedMessage

Modifier and Type	Method	Description
protected void	CachingAggregateRepository.handleEvents(List<SerializedMessage> messages)

Uses of SerializedMessage in io.fluxzero.sdk.persisting.search.client

Methods in io.fluxzero.sdk.persisting.search.client that return SerializedMessage

Modifier and Type	Method	Description
protected SerializedMessage	InMemorySearchStore.asSerializedMessage(SerializedDocument document)

Methods in io.fluxzero.sdk.persisting.search.client that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
List<SerializedMessage>	CollectionMessageStore.getBatch(Long minIndex, int maxSize, boolean inclusive)
Stream<SerializedMessage>	InMemorySearchStore.openStream(String collection, Long lastIndex, int maxSize)

Method parameters in io.fluxzero.sdk.persisting.search.client with type arguments of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	CollectionMessageStore.append(List<SerializedMessage> messages)
protected void	InMemorySearchStore.notifyMonitors(String collection, List<SerializedMessage> messages)
Registration	CollectionMessageStore.registerMonitor(Consumer<List<SerializedMessage>> monitor)
Registration	InMemorySearchStore.registerMonitor(String collection, Consumer<List<SerializedMessage>> monitor)
Registration	InMemorySearchStore.registerMonitor(BiConsumer<String, List<SerializedMessage>> monitor)

Uses of SerializedMessage in io.fluxzero.sdk.publishing

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

Modifier and Type	Method	Description
protected SerializedMessage	DefaultResultGateway.interceptDispatch(Object payload, Metadata metadata)
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.

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

Modifier and Type	Method	Description
CompletableFuture<SerializedMessage>	DefaultRequestHandler.ResponseCallback.finalCallback()	Returns the value of the finalCallback record component.
Consumer<SerializedMessage>	DefaultRequestHandler.ResponseCallback.intermediateCallback()	Returns the value of the intermediateCallback record component.
protected CompletableFuture<SerializedMessage>	DefaultRequestHandler.prepareRequest(SerializedMessage request, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
CompletableFuture<SerializedMessage>	DefaultRequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout)	Sends a request and processes the response, combining intermediate responses (if any) with the final response data.
CompletableFuture<SerializedMessage>	DefaultRequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
default CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender)	Sends a single request and returns a future that completes when the corresponding response is received.
CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout)	Sends a single request with a custom timeout and returns a future for the corresponding response.
CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
default CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Consumer<SerializedMessage> intermediateCallback)
List<CompletableFuture<SerializedMessage>>	DefaultRequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender)
List<CompletableFuture<SerializedMessage>>	DefaultRequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender, Duration timeout)
List<CompletableFuture<SerializedMessage>>	RequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender)	Sends multiple requests and returns a list of futures for their corresponding responses.
List<CompletableFuture<SerializedMessage>>	RequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender, Duration timeout)	Sends multiple requests with a custom timeout and returns a list of futures for their responses.

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

Modifier and Type	Method	Description
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.
protected CompletableFuture<SerializedMessage>	DefaultRequestHandler.prepareRequest(SerializedMessage request, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
CompletableFuture<SerializedMessage>	DefaultRequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout)	Sends a request and processes the response, combining intermediate responses (if any) with the final response data.
CompletableFuture<SerializedMessage>	DefaultRequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
default CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender)	Sends a single request and returns a future that completes when the corresponding response is received.
CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout)	Sends a single request with a custom timeout and returns a future for the corresponding response.
CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
default CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Consumer<SerializedMessage> intermediateCallback)

Method parameters in io.fluxzero.sdk.publishing with type arguments of type SerializedMessage

Modifier and Type	Method	Description
protected void	DefaultRequestHandler.handleResults(List<SerializedMessage> messages)
protected CompletableFuture<SerializedMessage>	DefaultRequestHandler.prepareRequest(SerializedMessage request, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
CompletableFuture<Void>	DefaultGenericGateway.sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)
CompletableFuture<Void>	GenericGateway.sendAndForget(Guarantee guarantee, UnaryOperator<SerializedMessage> interceptor, Message... messages)	Sends multiple Message objects with a guarantee.
CompletableFuture<SerializedMessage>	DefaultRequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout)	Sends a request and processes the response, combining intermediate responses (if any) with the final response data.
CompletableFuture<SerializedMessage>	DefaultRequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
default CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender)	Sends a single request and returns a future that completes when the corresponding response is received.
CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout)	Sends a single request with a custom timeout and returns a future for the corresponding response.
CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Duration timeout, Consumer<SerializedMessage> intermediateCallback)
default CompletableFuture<SerializedMessage>	RequestHandler.sendRequest(SerializedMessage request, Consumer<SerializedMessage> requestSender, Consumer<SerializedMessage> intermediateCallback)
List<CompletableFuture<SerializedMessage>>	DefaultRequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender)
List<CompletableFuture<SerializedMessage>>	DefaultRequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender)
List<CompletableFuture<SerializedMessage>>	DefaultRequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender, Duration timeout)
List<CompletableFuture<SerializedMessage>>	DefaultRequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender, Duration timeout)
List<CompletableFuture<SerializedMessage>>	RequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender)	Sends multiple requests and returns a list of futures for their corresponding responses.
List<CompletableFuture<SerializedMessage>>	RequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender)	Sends multiple requests and returns a list of futures for their corresponding responses.
List<CompletableFuture<SerializedMessage>>	RequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender, Duration timeout)	Sends multiple requests with a custom timeout and returns a list of futures for their responses.
List<CompletableFuture<SerializedMessage>>	RequestHandler.sendRequests(List<SerializedMessage> requests, Consumer<List<SerializedMessage>> requestSender, Duration timeout)	Sends multiple requests with a custom timeout and returns a list of futures for their responses.

Constructor parameters in io.fluxzero.sdk.publishing with type arguments of type SerializedMessage

Modifier	Constructor	Description
protected	ResponseCallback(Consumer<SerializedMessage> intermediateCallback, CompletableFuture<SerializedMessage> finalCallback)	Creates an instance of a ResponseCallback record class.
protected	ResponseCallback(Consumer<SerializedMessage> intermediateCallback, CompletableFuture<SerializedMessage> finalCallback)	Creates an instance of a ResponseCallback record class.

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

Subinterfaces with type arguments of type SerializedMessage in io.fluxzero.sdk.publishing.client

Modifier and Type	Interface	Description
interface	GatewayClient	Low-level interface for sending SerializedMessages to a gateway (e.g. commands, events, queries).

Methods in io.fluxzero.sdk.publishing.client with parameters of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	GatewayClient.append(Guarantee guarantee, SerializedMessage... messages)	Append the given messages to the gateway, applying the given delivery Guarantee.
CompletableFuture<Void>	WebsocketGatewayClient.append(Guarantee guarantee, SerializedMessage... messages)

Method parameters in io.fluxzero.sdk.publishing.client with type arguments of type SerializedMessage

Modifier and Type	Method	Description
Registration	WebsocketGatewayClient.registerMonitor(Consumer<List<SerializedMessage>> monitor)

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

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

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.

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

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

Modifier and Type	Method	Description
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.

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

Modifier and Type	Method	Description
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 SerializedMessage in io.fluxzero.sdk.scheduling.client

Methods in io.fluxzero.sdk.scheduling.client that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
protected Collection<SerializedMessage>	InMemoryScheduleStore.filterMessages(Collection<SerializedMessage> messages)

Methods in io.fluxzero.sdk.scheduling.client with parameters of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryScheduleStore.append(SerializedMessage... messages)

Method parameters in io.fluxzero.sdk.scheduling.client with type arguments of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryScheduleStore.append(List<SerializedMessage> messages)
protected Collection<SerializedMessage>	InMemoryScheduleStore.filterMessages(Collection<SerializedMessage> messages)

Uses of SerializedMessage in io.fluxzero.sdk.tracking

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

Modifier and Type	Method	Description
protected Consumer<List<SerializedMessage>>	DefaultTracking.createConsumer(ConsumerConfiguration config, List<Handler<DeserializingMessage>> handlers)

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

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

Modifier and Type	Method	Description
protected SerializedMessage	InMemoryMessageStore.getMessage(long index)

Methods in io.fluxzero.sdk.tracking.client that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
protected List<SerializedMessage>	CachingTrackingClient.filterMessages(List<SerializedMessage> messages, int[] segmentRange, Position position, ConsumerConfiguration config)
protected Collection<SerializedMessage>	InMemoryMessageStore.filterMessages(Collection<SerializedMessage> messages)
List<SerializedMessage>	InMemoryMessageStore.getBatch(Long minIndex, int maxSize, boolean inclusive)
List<SerializedMessage>	CachingTrackingClient.readFromIndex(long minIndex, int maxSize)
List<SerializedMessage>	LocalTrackingClient.readFromIndex(long minIndex, int maxSize)
List<SerializedMessage>	TrackingClient.readFromIndex(long minIndex, int maxSize)	Fetches messages starting from the given index up to the provided max size.
List<SerializedMessage>	WebsocketTrackingClient.readFromIndex(long minIndex, int maxSize)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	LocalTrackingClient.append(Guarantee guarantee, SerializedMessage... messages)

Method parameters in io.fluxzero.sdk.tracking.client with type arguments of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryMessageStore.append(List<SerializedMessage> messages)
protected void	CachingTrackingClient.cacheNewMessages(List<SerializedMessage> messages)
protected List<SerializedMessage>	CachingTrackingClient.filterMessages(List<SerializedMessage> messages, int[] segmentRange, Position position, ConsumerConfiguration config)
protected Collection<SerializedMessage>	InMemoryMessageStore.filterMessages(Collection<SerializedMessage> messages)
protected void	InMemoryMessageStore.notifyMonitors(List<SerializedMessage> messages)
Registration	InMemoryMessageStore.registerMonitor(Consumer<List<SerializedMessage>> monitor)
Registration	LocalTrackingClient.registerMonitor(Consumer<List<SerializedMessage>> monitor)
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.
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, ConsumerConfiguration config, TrackingClient trackingClient)	Starts one or more trackers that consume messages using the provided trackingClient and process them using the provided consumer.

Uses of SerializedMessage in io.fluxzero.sdk.web

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

Modifier and Type	Method	Description
protected SerializedMessage	WebResponseCompressingInterceptor.compress(SerializedMessage response)	Applies GZIP compression to the response payload and updates the metadata to indicate the Content-Encoding used.
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.
SerializedMessage	WebRequest.serialize(Serializer serializer)	Serializes the request using the content type if applicable.
SerializedMessage	WebResponse.serialize(Serializer serializer)	Serializes the response using the content type if applicable.
protected SerializedMessage	ForwardingWebConsumer.toMessage(Throwable error, Map<String,String> correlationData)
protected SerializedMessage	ForwardingWebConsumer.toMessage(HttpResponse<byte[]> response, Map<String,String> correlationData)

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

Modifier and Type	Method	Description
protected SerializedMessage	WebResponseCompressingInterceptor.compress(SerializedMessage response)	Applies GZIP compression to the response payload and updates the metadata to indicate the Content-Encoding used.
protected HttpRequest	ForwardingWebConsumer.createRequest(SerializedMessage m)
protected Map<String,String>	ForwardingWebConsumer.getCorrelationData(SerializedMessage m)
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.
protected boolean	WebResponseCompressingInterceptor.shouldCompress(SerializedMessage serializedMessage, WebResponse response)	Determines whether the given serialized message should be compressed based on specific criteria.

Method parameters in io.fluxzero.sdk.web with type arguments of type SerializedMessage

Modifier and Type	Method	Description
protected CompletableFuture<Void>	WebResponseGateway.sendResponse(WebResponse response, Function<SerializedMessage, CompletableFuture<Void>> dispatcher)

Uses of SerializedMessage in io.fluxzero.testserver.scheduling

Methods in io.fluxzero.testserver.scheduling that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
List<SerializedMessage>	TestServerScheduleStore.getBatch(Long minIndex, int maxSize)
List<SerializedMessage>	TestServerScheduleStore.getBatch(Long minIndex, int maxSize, boolean inclusive)