Uses of Interface
org.apache.camel.builder.component.dsl.IggyComponentBuilderFactory.IggyComponentBuilder
Packages that use IggyComponentBuilderFactory.IggyComponentBuilder
-
Uses of IggyComponentBuilderFactory.IggyComponentBuilder in org.apache.camel.builder.component
Methods in org.apache.camel.builder.component that return IggyComponentBuilderFactory.IggyComponentBuilderModifier and TypeMethodDescriptionComponentsBuilderFactory.iggy()Iggy (camel-iggy) Send and receive message to Apache Iggy streaming platform. -
Uses of IggyComponentBuilderFactory.IggyComponentBuilder in org.apache.camel.builder.component.dsl
Classes in org.apache.camel.builder.component.dsl that implement IggyComponentBuilderFactory.IggyComponentBuilderModifier and TypeClassDescriptionstatic classMethods in org.apache.camel.builder.component.dsl that return IggyComponentBuilderFactory.IggyComponentBuilderModifier and TypeMethodDescriptionIggyComponentBuilderFactory.IggyComponentBuilder.autoCommit(boolean autoCommit) Controls message acknowledgment behavior.IggyComponentBuilderFactory.IggyComponentBuilder.autoCreateStream(boolean autoCreateStream) Whether to automatically create stream if it does not exist.IggyComponentBuilderFactory.IggyComponentBuilder.autoCreateTopic(boolean autoCreateTopic) Whether to automatically create topic if it does not exist.IggyComponentBuilderFactory.IggyComponentBuilder.autowiredEnabled(boolean autowiredEnabled) Whether autowiring is enabled.IggyComponentBuilderFactory.IggyComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler.IggyComponentBuilderFactory.IggyComponentBuilder.clientTransport(String clientTransport) Polling strategy.IggyComponentBuilderFactory.IggyComponentBuilder.compressionAlgorithm(org.apache.iggy.topic.CompressionAlgorithm compressionAlgorithm) Compression algorithm for message payload.IggyComponentBuilderFactory.IggyComponentBuilder.configuration(org.apache.camel.component.iggy.IggyConfiguration configuration) Allows to pre-configure the Iggy component with common options that the endpoints will reuse.IggyComponentBuilderFactory.IggyComponentBuilder.consumerGroupName(String consumerGroupName) The name of the consumer group.IggyComponentBuilderFactory.IggyComponentBuilder.consumersCount(int consumersCount) Camel Iggy consumers count.Iggy server hostname or IP address.IggyComponentBuilderFactory.iggy()Iggy (camel-iggy) Send and receive message to Apache Iggy streaming platform.IggyComponentBuilderFactory.IggyComponentBuilder.lazyStartProducer(boolean lazyStartProducer) Whether the producer should be started lazy (on the first message).IggyComponentBuilderFactory.IggyComponentBuilder.maxTopicSize(Long maxTopicSize) Maximum topic size in bytes (0 means unlimited).IggyComponentBuilderFactory.IggyComponentBuilder.messageExpiry(Long messageExpiry) Message expiry time in seconds (0 means no expiry).IggyComponentBuilderFactory.IggyComponentBuilder.partitionId(Long partitionId) The consumer partition id.IggyComponentBuilderFactory.IggyComponentBuilder.partitioning(org.apache.iggy.message.Partitioning partitioning) Partitioning strategy for message distribution.IggyComponentBuilderFactory.IggyComponentBuilder.partitionsCount(Long partitionsCount) Number of partitions for the topic.Iggy password.IggyComponentBuilderFactory.IggyComponentBuilder.pollBatchSize(Long pollBatchSize) The consumer poll batch size.IggyComponentBuilderFactory.IggyComponentBuilder.pollingStrategy(String pollingStrategy) Polling strategy.IggyComponentBuilderFactory.IggyComponentBuilder.port(int port) Iggy server port number.IggyComponentBuilderFactory.IggyComponentBuilder.replicationFactor(Short replicationFactor) Replication factor for the topic.IggyComponentBuilderFactory.IggyComponentBuilder.shutdownTimeout(int shutdownTimeout) Camel Iggy shutdown timeout.IggyComponentBuilderFactory.IggyComponentBuilder.startingOffset(Long startingOffset) Defines the initial message offset position when autoCommit is disabled.Stream identifier.IggyComponentBuilderFactory.IggyComponentBuilder.streamName(String streamName) Stream name.Iggy username.