Uses of Interface
org.apache.camel.builder.endpoint.dsl.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder
Packages that use IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder
-
Uses of IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder in org.apache.camel.builder.endpoint.dsl
Subinterfaces of IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder in org.apache.camel.builder.endpoint.dslModifier and TypeInterfaceDescriptionstatic interfaceBuilder for endpoint for the Iggy component.Methods in org.apache.camel.builder.endpoint.dsl that return IggyEndpointBuilderFactory.IggyEndpointConsumerBuilderModifier and TypeMethodDescriptionIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.autoCommit(boolean autoCommit) Controls message acknowledgment behavior.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.autoCommit(String autoCommit) Controls message acknowledgment behavior.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.autoCreateStream(boolean autoCreateStream) Whether to automatically create stream if it does not exist.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.autoCreateStream(String autoCreateStream) Whether to automatically create stream if it does not exist.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.autoCreateTopic(boolean autoCreateTopic) Whether to automatically create topic if it does not exist.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.autoCreateTopic(String autoCreateTopic) Whether to automatically create topic if it does not exist.IggyEndpointBuilderFactory.AdvancedIggyEndpointConsumerBuilder.basic()IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.clientTransport(String clientTransport) Polling strategy.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.compressionAlgorithm(String compressionAlgorithm) Compression algorithm for message payload.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.compressionAlgorithm(org.apache.iggy.topic.CompressionAlgorithm compressionAlgorithm) Compression algorithm for message payload.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.consumerGroupName(String consumerGroupName) The name of the consumer group.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.consumersCount(int consumersCount) Camel Iggy consumers count.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.consumersCount(String consumersCount) Camel Iggy consumers count.Iggy server hostname or IP address.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.maxTopicSize(Long maxTopicSize) Maximum topic size in bytes (0 means unlimited).IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.maxTopicSize(String maxTopicSize) Maximum topic size in bytes (0 means unlimited).IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.messageExpiry(Long messageExpiry) Message expiry time in seconds (0 means no expiry).IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.messageExpiry(String messageExpiry) Message expiry time in seconds (0 means no expiry).IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.partitionId(Long partitionId) The consumer partition id.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.partitionId(String partitionId) The consumer partition id.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.partitionsCount(Long partitionsCount) Number of partitions for the topic.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.partitionsCount(String partitionsCount) Number of partitions for the topic.Iggy password.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.pollBatchSize(Long pollBatchSize) The consumer poll batch size.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.pollBatchSize(String pollBatchSize) The consumer poll batch size.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.pollingStrategy(String pollingStrategy) Polling strategy.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.port(int port) Iggy server port number.Iggy server port number.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.replicationFactor(Short replicationFactor) Replication factor for the topic.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.replicationFactor(String replicationFactor) Replication factor for the topic.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.shutdownTimeout(int shutdownTimeout) Camel Iggy shutdown timeout.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.shutdownTimeout(String shutdownTimeout) Camel Iggy shutdown timeout.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.startingOffset(Long startingOffset) Defines the initial message offset position when autoCommit is disabled.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.startingOffset(String startingOffset) Defines the initial message offset position when autoCommit is disabled.Stream identifier.Stream identifier.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder.streamName(String streamName) Stream name.Iggy username.