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

Interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder

All Superinterfaces:

org.apache.camel.builder.EndpointProducerBuilder, org.apache.camel.EndpointProducerResolver

All Known Subinterfaces:

IggyEndpointBuilderFactory.IggyEndpointBuilder

Enclosing interface:

IggyEndpointBuilderFactory

public static interface IggyEndpointBuilderFactory.IggyEndpointProducerBuilder
extends org.apache.camel.builder.EndpointProducerBuilder

Builder for endpoint producers for the Iggy component.

Method Summary

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

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

doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUri

Methods inherited from interface org.apache.camel.EndpointProducerResolver

resolve, resolve

Method Details

advanced

default IggyEndpointBuilderFactory.AdvancedIggyEndpointProducerBuilder advanced()

autoCreateStream

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder autoCreateStream(boolean autoCreateStream)

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

Parameters:

autoCreateStream - the value to set

Returns:

the dsl builder

autoCreateStream

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder 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

Parameters:

autoCreateStream - the value to set

Returns:

the dsl builder

autoCreateTopic

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder autoCreateTopic(boolean autoCreateTopic)

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

Parameters:

autoCreateTopic - the value to set

Returns:

the dsl builder

autoCreateTopic

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder 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

Parameters:

autoCreateTopic - the value to set

Returns:

the dsl builder

clientTransport

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder clientTransport(String clientTransport)

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

Parameters:

clientTransport - the value to set

Returns:

the dsl builder

compressionAlgorithm

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder 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

Parameters:

compressionAlgorithm - the value to set

Returns:

the dsl builder

compressionAlgorithm

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder 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

Parameters:

compressionAlgorithm - the value to set

Returns:

the dsl builder

host

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder host(String host)

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

Parameters:

host - the value to set

Returns:

the dsl builder

maxTopicSize

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder maxTopicSize(Long maxTopicSize)

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

Parameters:

maxTopicSize - the value to set

Returns:

the dsl builder

maxTopicSize

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder 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

Parameters:

maxTopicSize - the value to set

Returns:

the dsl builder

messageExpiry

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder messageExpiry(Long messageExpiry)

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

Parameters:

messageExpiry - the value to set

Returns:

the dsl builder

messageExpiry

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder 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

Parameters:

messageExpiry - the value to set

Returns:

the dsl builder

partitionsCount

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder partitionsCount(Long partitionsCount)

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

Parameters:

partitionsCount - the value to set

Returns:

the dsl builder

partitionsCount

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder partitionsCount(String partitionsCount)

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

Parameters:

partitionsCount - the value to set

Returns:

the dsl builder

password

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder password(String password)

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

Parameters:

password - the value to set

Returns:

the dsl builder

port

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder port(int port)

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

Parameters:

port - the value to set

Returns:

the dsl builder

port

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder port(String port)

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

Parameters:

port - the value to set

Returns:

the dsl builder

replicationFactor

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder replicationFactor(Short replicationFactor)

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

Parameters:

replicationFactor - the value to set

Returns:

the dsl builder

replicationFactor

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder replicationFactor(String replicationFactor)

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

Parameters:

replicationFactor - the value to set

Returns:

the dsl builder

streamId

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder streamId(Long streamId)

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

Parameters:

streamId - the value to set

Returns:

the dsl builder

streamId

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder streamId(String streamId)

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

Parameters:

streamId - the value to set

Returns:

the dsl builder

streamName

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder streamName(String streamName)

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

Parameters:

streamName - the value to set

Returns:

the dsl builder

partitioning

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder partitioning(org.apache.iggy.message.Partitioning partitioning)

Partitioning strategy for message distribution. The option is a: org.apache.iggy.message.Partitioning type. Default: balanced Group: producer

Parameters:

partitioning - the value to set

Returns:

the dsl builder

partitioning

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder partitioning(String partitioning)

Partitioning strategy for message distribution. The option will be converted to a org.apache.iggy.message.Partitioning type. Default: balanced Group: producer

Parameters:

partitioning - the value to set

Returns:

the dsl builder

username

default IggyEndpointBuilderFactory.IggyEndpointProducerBuilder username(String username)

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

Parameters:

username - the value to set

Returns:

the dsl builder