org.springframework.xd.dirt.integration.bus

Interface BusProperties

All Known Implementing Classes:

AbstractBusPropertiesAccessor

public interface BusProperties

Common bus properties.

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BACK_OFF_INITIAL_INTERVAL The retry back off initial interval.
static java.lang.String	BACK_OFF_MAX_INTERVAL The retry back off max interval.
static java.lang.String	BACK_OFF_MULTIPLIER The retry back off multiplier.
static java.lang.String	BATCH_BUFFER_LIMIT The buffer limit if batching is enabled.
static java.lang.String	BATCH_SIZE The batch size if batching is enabled.
static java.lang.String	BATCH_TIMEOUT The batch timeout if batching is enabled.
static java.lang.String	BATCHING_ENABLED True if message batching is enabled.
static java.lang.String	COMPRESS Compression enabled.
static java.lang.String	CONCURRENCY The minimum number of concurrent deliveries.
static java.lang.String	COUNT The number of consumers, i.e.
static java.lang.String	DIRECT_BINDING_ALLOWED If true, the bus will attempt to create a direct binding between the producer and consumer.
static java.lang.String	DURABLE Durable pub/sub consumer.
static java.lang.String	MAX_ATTEMPTS The maximum delivery attempts when a delivery fails.
static java.lang.String	MAX_CONCURRENCY The maximum number of concurrent deliveries.
static java.lang.String	MIN_PARTITION_COUNT Minimum partition count, if the transport supports partitioning natively (e.g.
static java.lang.String	NEXT_MODULE_CONCURRENCY For all non-terminal modules, the concurrency for module coming after this one.
static java.lang.String	NEXT_MODULE_COUNT For all non-terminal modules, the number of modules coming after this one, irrespective of partitioning.
static java.lang.String	PARTITION_INDEX The consumer's partition index.
static java.lang.String	PARTITION_KEY_EXPRESSION The partition key expression.
static java.lang.String	PARTITION_KEY_EXTRACTOR_CLASS The partition key class.
static java.lang.String	PARTITION_SELECTOR_CLASS The partition selector class.
static java.lang.String	PARTITION_SELECTOR_EXPRESSION The partition selector expression.
static java.lang.String	SEQUENCE The sequence index of the module.

Field Detail

BACK_OFF_INITIAL_INTERVAL

static final java.lang.String BACK_OFF_INITIAL_INTERVAL

The retry back off initial interval.

See Also:

Constant Field Values

BACK_OFF_MAX_INTERVAL

static final java.lang.String BACK_OFF_MAX_INTERVAL

The retry back off max interval.

See Also:

Constant Field Values

BACK_OFF_MULTIPLIER

static final java.lang.String BACK_OFF_MULTIPLIER

The retry back off multiplier.

See Also:

Constant Field Values

CONCURRENCY

static final java.lang.String CONCURRENCY

The minimum number of concurrent deliveries.

See Also:

Constant Field Values

MAX_ATTEMPTS

static final java.lang.String MAX_ATTEMPTS

The maximum delivery attempts when a delivery fails.

See Also:

Constant Field Values

MAX_CONCURRENCY

static final java.lang.String MAX_CONCURRENCY

The maximum number of concurrent deliveries.

See Also:

Constant Field Values

SEQUENCE

static final java.lang.String SEQUENCE

The sequence index of the module. In a partitioned stream, it is identical to the partition index.

See Also:

Constant Field Values

COUNT

static final java.lang.String COUNT

The number of consumers, i.e. module instances in the stream. In a partitioned stream, it is identical to the partition count.

See Also:

Constant Field Values

PARTITION_INDEX

static final java.lang.String PARTITION_INDEX

The consumer's partition index.

See Also:

Constant Field Values

PARTITION_KEY_EXPRESSION

static final java.lang.String PARTITION_KEY_EXPRESSION

The partition key expression.

See Also:

Constant Field Values

PARTITION_KEY_EXTRACTOR_CLASS

static final java.lang.String PARTITION_KEY_EXTRACTOR_CLASS

The partition key class.

See Also:

Constant Field Values

PARTITION_SELECTOR_CLASS

static final java.lang.String PARTITION_SELECTOR_CLASS

The partition selector class.

See Also:

Constant Field Values

PARTITION_SELECTOR_EXPRESSION

static final java.lang.String PARTITION_SELECTOR_EXPRESSION

The partition selector expression.

See Also:

Constant Field Values

DIRECT_BINDING_ALLOWED

static final java.lang.String DIRECT_BINDING_ALLOWED

If true, the bus will attempt to create a direct binding between the producer and consumer.

See Also:

Constant Field Values

BATCHING_ENABLED

static final java.lang.String BATCHING_ENABLED

True if message batching is enabled.

See Also:

Constant Field Values

BATCH_SIZE

static final java.lang.String BATCH_SIZE

The batch size if batching is enabled.

See Also:

Constant Field Values

BATCH_BUFFER_LIMIT

static final java.lang.String BATCH_BUFFER_LIMIT

The buffer limit if batching is enabled.

See Also:

Constant Field Values

BATCH_TIMEOUT

static final java.lang.String BATCH_TIMEOUT

The batch timeout if batching is enabled.

See Also:

Constant Field Values

NEXT_MODULE_COUNT

static final java.lang.String NEXT_MODULE_COUNT

For all non-terminal modules, the number of modules coming after this one, irrespective of partitioning.

See Also:

Constant Field Values

NEXT_MODULE_CONCURRENCY

static final java.lang.String NEXT_MODULE_CONCURRENCY

For all non-terminal modules, the concurrency for module coming after this one.

See Also:

Constant Field Values

COMPRESS

static final java.lang.String COMPRESS

Compression enabled.

See Also:

Constant Field Values

DURABLE

static final java.lang.String DURABLE

Durable pub/sub consumer.

See Also:

Constant Field Values

MIN_PARTITION_COUNT

static final java.lang.String MIN_PARTITION_COUNT

Minimum partition count, if the transport supports partitioning natively (e.g. Kafka)

See Also:

Constant Field Values