Package org.apache.camel.builder.endpoint.dsl

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 Type	Method	Description
default IggyEndpointBuilderFactory.AdvancedIggyEndpointBuilder	advanced()
default IggyEndpointBuilderFactory.IggyEndpointBuilder	autoCreateStream(boolean autoCreateStream)	Whether to automatically create stream if it does not exist.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	autoCreateStream(String autoCreateStream)	Whether to automatically create stream if it does not exist.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	autoCreateTopic(boolean autoCreateTopic)	Whether to automatically create topic if it does not exist.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	autoCreateTopic(String autoCreateTopic)	Whether to automatically create topic if it does not exist.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	clientTransport(String clientTransport)	Polling strategy.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	compressionAlgorithm(String compressionAlgorithm)	Compression algorithm for message payload.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	compressionAlgorithm(org.apache.iggy.topic.CompressionAlgorithm compressionAlgorithm)	Compression algorithm for message payload.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	host(String host)	Iggy server hostname or IP address.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	maxTopicSize(Long maxTopicSize)	Maximum topic size in bytes (0 means unlimited).
default IggyEndpointBuilderFactory.IggyEndpointBuilder	maxTopicSize(String maxTopicSize)	Maximum topic size in bytes (0 means unlimited).
default IggyEndpointBuilderFactory.IggyEndpointBuilder	messageExpiry(Long messageExpiry)	Message expiry time in seconds (0 means no expiry).
default IggyEndpointBuilderFactory.IggyEndpointBuilder	messageExpiry(String messageExpiry)	Message expiry time in seconds (0 means no expiry).
default IggyEndpointBuilderFactory.IggyEndpointBuilder	partitionsCount(Long partitionsCount)	Number of partitions for the topic.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	partitionsCount(String partitionsCount)	Number of partitions for the topic.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	password(String password)	Iggy password.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	port(int port)	Iggy server port number.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	port(String port)	Iggy server port number.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	replicationFactor(Short replicationFactor)	Replication factor for the topic.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	replicationFactor(String replicationFactor)	Replication factor for the topic.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	streamId(Long streamId)	Stream identifier.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	streamId(String streamId)	Stream identifier.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	streamName(String streamName)	Stream name.
default IggyEndpointBuilderFactory.IggyEndpointBuilder	username(String username)	Iggy username.

Methods inherited from interface org.apache.camel.builder.EndpointConsumerBuilder

doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUri

Methods inherited from interface org.apache.camel.EndpointConsumerResolver

resolve, resolve

Methods inherited from interface org.apache.camel.builder.EndpointProducerBuilder

doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUri

Methods inherited from interface org.apache.camel.EndpointProducerResolver

resolve, resolve

Methods inherited from interface org.apache.camel.builder.endpoint.dsl.IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

autoCommit, autoCommit, consumerGroupName, consumersCount, consumersCount, partitionId, partitionId, pollBatchSize, pollBatchSize, pollingStrategy, shutdownTimeout, shutdownTimeout, startingOffset, startingOffset

Methods inherited from interface org.apache.camel.builder.endpoint.dsl.IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

partitioning, partitioning

Method Details

advanced

default IggyEndpointBuilderFactory.AdvancedIggyEndpointBuilder advanced()

Specified by:

advanced in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

advanced in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

autoCreateStream

default IggyEndpointBuilderFactory.IggyEndpointBuilder autoCreateStream(boolean autoCreateStream)

Whether to automatically create stream if it does not exist. The option is a: boolean type. Default: true Group: common

Specified by:

autoCreateStream in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

autoCreateStream in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

autoCreateStream - the value to set

Returns:

the dsl builder

autoCreateStream

default IggyEndpointBuilderFactory.IggyEndpointBuilder autoCreateStream(String autoCreateStream)

Whether to automatically create stream if it does not exist. The option will be converted to a boolean type. Default: true Group: common

Specified by:

autoCreateStream in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

autoCreateStream in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

autoCreateStream - the value to set

Returns:

the dsl builder

autoCreateTopic

default IggyEndpointBuilderFactory.IggyEndpointBuilder autoCreateTopic(boolean autoCreateTopic)

Whether to automatically create topic if it does not exist. The option is a: boolean type. Default: true Group: common

Specified by:

autoCreateTopic in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

autoCreateTopic in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

autoCreateTopic - the value to set

Returns:

the dsl builder

autoCreateTopic

default IggyEndpointBuilderFactory.IggyEndpointBuilder autoCreateTopic(String autoCreateTopic)

Whether to automatically create topic if it does not exist. The option will be converted to a boolean type. Default: true Group: common

Specified by:

autoCreateTopic in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

autoCreateTopic in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

autoCreateTopic - the value to set

Returns:

the dsl builder

clientTransport

default IggyEndpointBuilderFactory.IggyEndpointBuilder clientTransport(String clientTransport)

Polling strategy. The option is a: java.lang.String type. Default: TCP Group: common

Specified by:

clientTransport in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

clientTransport in interface IggyEndpointBuilderFactory.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.CompressionAlgorithm type. Default: None Group: common

Specified by:

compressionAlgorithm in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

compressionAlgorithm in interface IggyEndpointBuilderFactory.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 a org.apache.iggy.topic.CompressionAlgorithm type. Default: None Group: common

Specified by:

compressionAlgorithm in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

compressionAlgorithm in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

compressionAlgorithm - the value to set

Returns:

the dsl builder

host

default IggyEndpointBuilderFactory.IggyEndpointBuilder host(String host)

Iggy server hostname or IP address. The option is a: java.lang.String type. Default: localhost Group: common

Specified by:

host in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

host in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

host - the value to set

Returns:

the dsl builder

maxTopicSize

default IggyEndpointBuilderFactory.IggyEndpointBuilder maxTopicSize(Long maxTopicSize)

Maximum topic size in bytes (0 means unlimited). The option is a: java.lang.Long type. Default: 0 Group: common

Specified by:

maxTopicSize in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

maxTopicSize in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

maxTopicSize - the value to set

Returns:

the dsl builder

maxTopicSize

default IggyEndpointBuilderFactory.IggyEndpointBuilder maxTopicSize(String maxTopicSize)

Maximum topic size in bytes (0 means unlimited). The option will be converted to a java.lang.Long type. Default: 0 Group: common

Specified by:

maxTopicSize in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

maxTopicSize in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

maxTopicSize - the value to set

Returns:

the dsl builder

messageExpiry

default IggyEndpointBuilderFactory.IggyEndpointBuilder messageExpiry(Long messageExpiry)

Message expiry time in seconds (0 means no expiry). The option is a: java.lang.Long type. Default: 0 Group: common

Specified by:

messageExpiry in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

messageExpiry in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

messageExpiry - the value to set

Returns:

the dsl builder

messageExpiry

default IggyEndpointBuilderFactory.IggyEndpointBuilder messageExpiry(String messageExpiry)

Message expiry time in seconds (0 means no expiry). The option will be converted to a java.lang.Long type. Default: 0 Group: common

Specified by:

messageExpiry in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

messageExpiry in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

messageExpiry - the value to set

Returns:

the dsl builder

partitionsCount

default IggyEndpointBuilderFactory.IggyEndpointBuilder partitionsCount(Long partitionsCount)

Number of partitions for the topic. The option is a: java.lang.Long type. Default: 1 Group: common

Specified by:

partitionsCount in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

partitionsCount in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

partitionsCount - the value to set

Returns:

the dsl builder

partitionsCount

default IggyEndpointBuilderFactory.IggyEndpointBuilder partitionsCount(String partitionsCount)

Number of partitions for the topic. The option will be converted to a java.lang.Long type. Default: 1 Group: common

Specified by:

partitionsCount in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

partitionsCount in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

partitionsCount - the value to set

Returns:

the dsl builder

password

default IggyEndpointBuilderFactory.IggyEndpointBuilder password(String password)

Iggy password. The option is a: java.lang.String type. Group: common

Specified by:

password in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

password in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

password - the value to set

Returns:

the dsl builder

port

default IggyEndpointBuilderFactory.IggyEndpointBuilder port(int port)

Iggy server port number. The option is a: int type. Default: 8090 Group: common

Specified by:

port in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

port in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

port - the value to set

Returns:

the dsl builder

port

default IggyEndpointBuilderFactory.IggyEndpointBuilder port(String port)

Iggy server port number. The option will be converted to a int type. Default: 8090 Group: common

Specified by:

port in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

port in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

port - the value to set

Returns:

the dsl builder

replicationFactor

default IggyEndpointBuilderFactory.IggyEndpointBuilder replicationFactor(Short replicationFactor)

Replication factor for the topic. The option is a: java.lang.Short type. Group: common

Specified by:

replicationFactor in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

replicationFactor in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

replicationFactor - the value to set

Returns:

the dsl builder

replicationFactor

default IggyEndpointBuilderFactory.IggyEndpointBuilder replicationFactor(String replicationFactor)

Replication factor for the topic. The option will be converted to a java.lang.Short type. Group: common

Specified by:

replicationFactor in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

replicationFactor in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

replicationFactor - the value to set

Returns:

the dsl builder

streamId

default IggyEndpointBuilderFactory.IggyEndpointBuilder streamId(Long streamId)

Stream identifier. The option is a: java.lang.Long type. Group: common

Specified by:

streamId in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

streamId in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

streamId - the value to set

Returns:

the dsl builder

streamId

default IggyEndpointBuilderFactory.IggyEndpointBuilder streamId(String streamId)

Stream identifier. The option will be converted to a java.lang.Long type. Group: common

Specified by:

streamId in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

streamId in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

streamId - the value to set

Returns:

the dsl builder

streamName

default IggyEndpointBuilderFactory.IggyEndpointBuilder streamName(String streamName)

Stream name. The option is a: java.lang.String type. Group: common

Specified by:

streamName in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

streamName in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

streamName - the value to set

Returns:

the dsl builder

username

default IggyEndpointBuilderFactory.IggyEndpointBuilder username(String username)

Iggy username. The option is a: java.lang.String type. Group: security

Specified by:

username in interface IggyEndpointBuilderFactory.IggyEndpointConsumerBuilder

Specified by:

username in interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

Parameters:

username - the value to set

Returns:

the dsl builder