Uses of Class
io.fluxcapacitor.javaclient.tracking.ConsumerConfiguration
Packages that use ConsumerConfiguration
Package
Description
-
Uses of ConsumerConfiguration in io.fluxcapacitor.javaclient.configuration
Methods in io.fluxcapacitor.javaclient.configuration that return ConsumerConfigurationModifier and TypeMethodDescriptionprotected ConsumerConfiguration
DefaultFluxCapacitor.Builder.getDefaultConsumerConfiguration
(MessageType messageType) Methods in io.fluxcapacitor.javaclient.configuration that return types with arguments of type ConsumerConfigurationModifier and TypeMethodDescriptionFluxCapacitorConfiguration.customConsumerConfigurations()
Provides custom consumer configurations per message type.FluxCapacitorConfiguration.defaultConsumerConfigurations()
Provides the default consumer configuration per message type.Methods in io.fluxcapacitor.javaclient.configuration with parameters of type ConsumerConfigurationModifier and TypeMethodDescriptionDefaultFluxCapacitor.Builder.addConsumerConfiguration
(@NonNull ConsumerConfiguration configuration, MessageType... messageTypes) FluxCapacitorBuilder.addConsumerConfiguration
(ConsumerConfiguration consumerConfiguration, MessageType... messageTypes) Adds a specific consumer configuration for one or more message types.Method parameters in io.fluxcapacitor.javaclient.configuration with type arguments of type ConsumerConfigurationModifier and TypeMethodDescriptionDefaultFluxCapacitor.Builder.configureDefaultConsumer
(@NonNull MessageType messageType, @NonNull UnaryOperator<ConsumerConfiguration> updateFunction) FluxCapacitorBuilder.configureDefaultConsumer
(MessageType messageType, UnaryOperator<ConsumerConfiguration> updateFunction) Update the default consumer configuration for the specified message type.DefaultFluxCapacitor.Builder.forwardWebRequestsToLocalServer
(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator) FluxCapacitorBuilder.forwardWebRequestsToLocalServer
(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator) Configures forwarding ofMessageType.WEBREQUEST
messages to a local HTTP server using the specifiedLocalServerConfig
and custom consumer configuration. -
Uses of ConsumerConfiguration in io.fluxcapacitor.javaclient.tracking
Methods in io.fluxcapacitor.javaclient.tracking that return types with arguments of type ConsumerConfigurationModifier and TypeMethodDescriptionstatic Stream
<ConsumerConfiguration> ConsumerConfiguration.configurations
(Collection<Class<?>> handlerClasses) Returns a stream ofConsumerConfiguration
s by inspecting the given handler classes and their packages.Methods in io.fluxcapacitor.javaclient.tracking with parameters of type ConsumerConfigurationModifier and TypeMethodDescriptionprotected Consumer
<List<SerializedMessage>> DefaultTracking.createConsumer
(ConsumerConfiguration config, List<Handler<DeserializingMessage>> handlers) protected Optional
<HandlerInvoker> DefaultTracking.getInvoker
(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config) protected Object
DefaultTracking.handle
(DeserializingMessage message, HandlerInvoker h, Handler<DeserializingMessage> handler, ConsumerConfiguration config) protected Object
DefaultTracking.processError
(Throwable e, DeserializingMessage message, HandlerInvoker h, Handler<DeserializingMessage> handler, ConsumerConfiguration config) protected void
DefaultTracking.reportResult
(Object result, HandlerInvoker h, DeserializingMessage message, ConsumerConfiguration config) protected boolean
DefaultTracking.shouldSendResponse
(HandlerInvoker invoker, DeserializingMessage request, Object result, ConsumerConfiguration config) protected Registration
DefaultTracking.startTracking
(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> handlers, FluxCapacitor fluxCapacitor) protected void
DefaultTracking.tryHandle
(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config, boolean reportResult) -
Uses of ConsumerConfiguration in io.fluxcapacitor.javaclient.tracking.client
Methods in io.fluxcapacitor.javaclient.tracking.client with parameters of type ConsumerConfigurationModifier and TypeMethodDescriptionCachingTrackingClient.claimSegment
(String trackerId, Long lastIndex, ConsumerConfiguration config) LocalTrackingClient.claimSegment
(String trackerId, Long lastIndex, ConsumerConfiguration config) TrackingClient.claimSegment
(String trackerId, Long lastIndex, ConsumerConfiguration config) Claims a processing segment for the given tracker.WebsocketTrackingClient.claimSegment
(String trackerId, Long lastIndex, ConsumerConfiguration config) protected List
<SerializedMessage> CachingTrackingClient.filterMessages
(List<SerializedMessage> messages, int[] segmentRange, Position position, ConsumerConfiguration config) protected MessageBatch
CachingTrackingClient.getMessageBatch
(ConsumerConfiguration config, long minIndex, ClaimSegmentResult claim) CachingTrackingClient.read
(String trackerId, Long lastIndex, ConsumerConfiguration config) LocalTrackingClient.read
(String trackerId, Long lastIndex, ConsumerConfiguration config) TrackingClient.read
(String trackerId, Long lastIndex, ConsumerConfiguration trackingConfiguration) Asynchronously reads the next availableMessageBatch
for a given tracker.WebsocketTrackingClient.read
(String trackerId, Long lastIndex, ConsumerConfiguration configuration) default MessageBatch
TrackingClient.readAndWait
(String trackerId, Long lastIndex, ConsumerConfiguration configuration) Reads the next availableMessageBatch
for the given tracker and blocks until messages are available.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, FluxCapacitor fluxCapacitor) 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, FluxCapacitor fluxCapacitor) 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 ConsumerConfiguration in io.fluxcapacitor.javaclient.web
Constructors in io.fluxcapacitor.javaclient.web with parameters of type ConsumerConfigurationModifierConstructorDescriptionForwardingWebConsumer
(LocalServerConfig localServerConfig, ConsumerConfiguration configuration)