Interface IggyEndpointBuilderFactory.IggyEndpointBuilder
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder,org.apache.camel.EndpointConsumerResolver,org.apache.camel.builder.EndpointProducerBuilder,org.apache.camel.EndpointProducerResolver,IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder,IggyEndpointBuilderFactory.IggyEndpointProducerBuilder
- Enclosing interface:
IggyEndpointBuilderFactory
public static interface IggyEndpointBuilderFactory.IggyEndpointBuilder
extends IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder, IggyEndpointBuilderFactory.IggyEndpointProducerBuilder
Builder for endpoint for the Iggy component.
-
Method Summary
Modifier and TypeMethodDescriptionadvanced()autoCreateStream(boolean autoCreateStream) Whether to automatically create stream if it does not exist.autoCreateStream(String autoCreateStream) Whether to automatically create stream if it does not exist.autoCreateTopic(boolean autoCreateTopic) Whether to automatically create topic if it does not exist.autoCreateTopic(String autoCreateTopic) Whether to automatically create topic if it does not exist.clientTransport(String clientTransport) Polling strategy.compressionAlgorithm(String compressionAlgorithm) Compression algorithm for message payload.compressionAlgorithm(org.apache.iggy.topic.CompressionAlgorithm compressionAlgorithm) Compression algorithm for message payload.Iggy server hostname or IP address.maxTopicSize(Long maxTopicSize) Maximum topic size in bytes (0 means unlimited).maxTopicSize(String maxTopicSize) Maximum topic size in bytes (0 means unlimited).messageExpiry(Long messageExpiry) Message expiry time in seconds (0 means no expiry).messageExpiry(String messageExpiry) Message expiry time in seconds (0 means no expiry).partitionsCount(Long partitionsCount) Number of partitions for the topic.partitionsCount(String partitionsCount) Number of partitions for the topic.Iggy password.port(int port) Iggy server port number.Iggy server port number.replicationFactor(Short replicationFactor) Replication factor for the topic.replicationFactor(String replicationFactor) Replication factor for the topic.Stream identifier.Stream identifier.streamName(String streamName) Stream name.Iggy username.Methods inherited from interface org.apache.camel.builder.EndpointConsumerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUriMethods inherited from interface org.apache.camel.EndpointConsumerResolver
resolve, resolveMethods inherited from interface org.apache.camel.builder.EndpointProducerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUriMethods inherited from interface org.apache.camel.EndpointProducerResolver
resolve, resolveMethods inherited from interface org.apache.camel.builder.endpoint.dsl.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder
autoCommit, autoCommit, consumerGroupName, consumersCount, consumersCount, partitionId, partitionId, pollBatchSize, pollBatchSize, pollingStrategy, shutdownTimeout, shutdownTimeout, startingOffset, startingOffsetMethods inherited from interface org.apache.camel.builder.endpoint.dsl.IggyEndpointBuilderFactory.IggyEndpointProducerBuilder
partitioning, partitioning
-
Method Details
-
advanced
- Specified by:
advancedin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
advancedin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder
-
autoCreateStream
Whether to automatically create stream if it does not exist. The option is a:booleantype. Default: true Group: common- Specified by:
autoCreateStreamin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
autoCreateStreamin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
autoCreateStream- the value to set- Returns:
- the dsl builder
-
autoCreateStream
Whether to automatically create stream if it does not exist. The option will be converted to abooleantype. Default: true Group: common- Specified by:
autoCreateStreamin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
autoCreateStreamin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
autoCreateStream- the value to set- Returns:
- the dsl builder
-
autoCreateTopic
Whether to automatically create topic if it does not exist. The option is a:booleantype. Default: true Group: common- Specified by:
autoCreateTopicin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
autoCreateTopicin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
autoCreateTopic- the value to set- Returns:
- the dsl builder
-
autoCreateTopic
Whether to automatically create topic if it does not exist. The option will be converted to abooleantype. Default: true Group: common- Specified by:
autoCreateTopicin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
autoCreateTopicin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
autoCreateTopic- the value to set- Returns:
- the dsl builder
-
clientTransport
Polling strategy. The option is a:java.lang.Stringtype. Default: TCP Group: common- Specified by:
clientTransportin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
clientTransportin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
clientTransport- the value to set- Returns:
- the dsl builder
-
compressionAlgorithm
default IggyEndpointBuilderFactory.IggyEndpointBuilder compressionAlgorithm(org.apache.iggy.topic.CompressionAlgorithm compressionAlgorithm) Compression algorithm for message payload. The option is a:org.apache.iggy.topic.CompressionAlgorithmtype. Default: None Group: common- Specified by:
compressionAlgorithmin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
compressionAlgorithmin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
compressionAlgorithm- the value to set- Returns:
- the dsl builder
-
compressionAlgorithm
default IggyEndpointBuilderFactory.IggyEndpointBuilder compressionAlgorithm(String compressionAlgorithm) Compression algorithm for message payload. The option will be converted to aorg.apache.iggy.topic.CompressionAlgorithmtype. Default: None Group: common- Specified by:
compressionAlgorithmin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
compressionAlgorithmin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
compressionAlgorithm- the value to set- Returns:
- the dsl builder
-
host
Iggy server hostname or IP address. The option is a:java.lang.Stringtype. Default: localhost Group: common- Specified by:
hostin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
hostin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
host- the value to set- Returns:
- the dsl builder
-
maxTopicSize
Maximum topic size in bytes (0 means unlimited). The option is a:java.lang.Longtype. Default: 0 Group: common- Specified by:
maxTopicSizein interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
maxTopicSizein interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
maxTopicSize- the value to set- Returns:
- the dsl builder
-
maxTopicSize
Maximum topic size in bytes (0 means unlimited). The option will be converted to ajava.lang.Longtype. Default: 0 Group: common- Specified by:
maxTopicSizein interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
maxTopicSizein interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
maxTopicSize- the value to set- Returns:
- the dsl builder
-
messageExpiry
Message expiry time in seconds (0 means no expiry). The option is a:java.lang.Longtype. Default: 0 Group: common- Specified by:
messageExpiryin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
messageExpiryin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
messageExpiry- the value to set- Returns:
- the dsl builder
-
messageExpiry
Message expiry time in seconds (0 means no expiry). The option will be converted to ajava.lang.Longtype. Default: 0 Group: common- Specified by:
messageExpiryin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
messageExpiryin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
messageExpiry- the value to set- Returns:
- the dsl builder
-
partitionsCount
Number of partitions for the topic. The option is a:java.lang.Longtype. Default: 1 Group: common- Specified by:
partitionsCountin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
partitionsCountin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
partitionsCount- the value to set- Returns:
- the dsl builder
-
partitionsCount
Number of partitions for the topic. The option will be converted to ajava.lang.Longtype. Default: 1 Group: common- Specified by:
partitionsCountin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
partitionsCountin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
partitionsCount- the value to set- Returns:
- the dsl builder
-
password
Iggy password. The option is a:java.lang.Stringtype. Group: common- Specified by:
passwordin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
passwordin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
password- the value to set- Returns:
- the dsl builder
-
port
Iggy server port number. The option is a:inttype. Default: 8090 Group: common- Specified by:
portin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
portin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
port- the value to set- Returns:
- the dsl builder
-
port
Iggy server port number. The option will be converted to ainttype. Default: 8090 Group: common- Specified by:
portin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
portin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
port- the value to set- Returns:
- the dsl builder
-
replicationFactor
Replication factor for the topic. The option is a:java.lang.Shorttype. Group: common- Specified by:
replicationFactorin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
replicationFactorin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
replicationFactor- the value to set- Returns:
- the dsl builder
-
replicationFactor
Replication factor for the topic. The option will be converted to ajava.lang.Shorttype. Group: common- Specified by:
replicationFactorin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
replicationFactorin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
replicationFactor- the value to set- Returns:
- the dsl builder
-
streamId
Stream identifier. The option is a:java.lang.Longtype. Group: common- Specified by:
streamIdin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
streamIdin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
streamId- the value to set- Returns:
- the dsl builder
-
streamId
Stream identifier. The option will be converted to ajava.lang.Longtype. Group: common- Specified by:
streamIdin interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
streamIdin interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
streamId- the value to set- Returns:
- the dsl builder
-
streamName
Stream name. The option is a:java.lang.Stringtype. Group: common- Specified by:
streamNamein interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
streamNamein interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
streamName- the value to set- Returns:
- the dsl builder
-
username
Iggy username. The option is a:java.lang.Stringtype. Group: security- Specified by:
usernamein interfaceIggyEndpointBuilderFactory.IggyEndpointConsumerBuilder- Specified by:
usernamein interfaceIggyEndpointBuilderFactory.IggyEndpointProducerBuilder- Parameters:
username- the value to set- Returns:
- the dsl builder
-