Uses of Class
io.fluxzero.sdk.tracking.ConsumerConfiguration

Packages that use ConsumerConfiguration

Package	Description
io.fluxzero.sdk.configuration
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.web

Uses of ConsumerConfiguration in io.fluxzero.sdk.configuration

Methods in io.fluxzero.sdk.configuration that return ConsumerConfiguration

Modifier and Type	Method	Description
protected ConsumerConfiguration	DefaultFluxzero.Builder.getDefaultConsumerConfiguration(MessageType messageType)

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

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.

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

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

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

Modifier and Type	Method	Description
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.
FluxzeroBuilder	DefaultFluxzero.Builder.forwardWebRequestsToLocalServer(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator)
FluxzeroBuilder	FluxzeroBuilder.forwardWebRequestsToLocalServer(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator)	Configures forwarding of MessageType.WEBREQUEST messages to a local HTTP server using the specified LocalServerConfig and custom consumer configuration.

Uses of ConsumerConfiguration in io.fluxzero.sdk.tracking

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

Modifier and Type	Method	Description
static Stream<ConsumerConfiguration>	ConsumerConfiguration.configurations(Collection<Class<?>> handlerClasses)	Returns a stream of ConsumerConfigurations by inspecting the given handler classes and their packages.

Methods in io.fluxzero.sdk.tracking with parameters of type ConsumerConfiguration

Modifier and Type	Method	Description
protected 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, Fluxzero fluxzero)
protected void	DefaultTracking.tryHandle(DeserializingMessage message, Handler<DeserializingMessage> handler, ConsumerConfiguration config, boolean reportResult)

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

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

Modifier and Type	Method	Description
CompletableFuture<ClaimSegmentResult>	CachingTrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<ClaimSegmentResult>	LocalTrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<ClaimSegmentResult>	TrackingClient.claimSegment(String trackerId, Long lastIndex, ConsumerConfiguration config)	Claims a processing segment for the given tracker.
CompletableFuture<ClaimSegmentResult>	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)
CompletableFuture<MessageBatch>	CachingTrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<MessageBatch>	LocalTrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration config)
CompletableFuture<MessageBatch>	TrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration trackingConfiguration)	Asynchronously reads the next available MessageBatch for a given tracker.
CompletableFuture<MessageBatch>	WebsocketTrackingClient.read(String trackerId, Long lastIndex, ConsumerConfiguration configuration)
default MessageBatch	TrackingClient.readAndWait(String trackerId, Long lastIndex, ConsumerConfiguration configuration)	Reads the next available MessageBatch 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, 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 ConsumerConfiguration in io.fluxzero.sdk.web

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

Modifier	Constructor	Description
	ForwardingWebConsumer(LocalServerConfig localServerConfig, ConsumerConfiguration configuration)