Package com.azure.spring.cloud.service.eventhubs.properties

Class LoadBalancingProperties

java.lang.Object

com.azure.spring.cloud.service.eventhubs.properties.LoadBalancingProperties

All Implemented Interfaces:

com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

public class LoadBalancingProperties
extends Object
implements com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Event processor load balancing properties.

Constructor Summary

Constructors

Constructor	Description
LoadBalancingProperties()	Creates an instance of LoadBalancingProperties.

Method Summary

Modifier and Type	Method	Description
Duration	getPartitionOwnershipExpirationInterval()	Get the time duration after which the ownership of partition expires.
com.azure.messaging.eventhubs.LoadBalancingStrategy	getStrategy()	Get the load balancing strategy for claiming partition ownership.
Duration	getUpdateInterval()	Get the time interval between load balancing update cycles.
void	setPartitionOwnershipExpirationInterval(Duration partitionOwnershipExpirationInterval)	Set the partition ownership expiration interval.
void	setStrategy(com.azure.messaging.eventhubs.LoadBalancingStrategy strategy)	Set the load balancing strategy.
void	setUpdateInterval(Duration updateInterval)	Set the update interval.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LoadBalancingProperties

public LoadBalancingProperties()

Creates an instance of LoadBalancingProperties.

Method Details

getUpdateInterval

public Duration getUpdateInterval()

Description copied from interface: com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Get the time interval between load balancing update cycles.

Specified by:

getUpdateInterval in interface com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Returns:

the update interval.

setUpdateInterval

public void setUpdateInterval(Duration updateInterval)

Set the update interval.

Parameters:

updateInterval - The update interval.

getStrategy

public com.azure.messaging.eventhubs.LoadBalancingStrategy getStrategy()

Description copied from interface: com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Get the load balancing strategy for claiming partition ownership.

Specified by:

getStrategy in interface com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Returns:

the load balancing strategy.

setStrategy

public void setStrategy(com.azure.messaging.eventhubs.LoadBalancingStrategy strategy)

Set the load balancing strategy.

Parameters:

strategy - The load balancing strategy.

getPartitionOwnershipExpirationInterval

public Duration getPartitionOwnershipExpirationInterval()

Description copied from interface: com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Get the time duration after which the ownership of partition expires.

Specified by:

getPartitionOwnershipExpirationInterval in interface com.azure.spring.cloud.service.implementation.eventhubs.properties.EventProcessorClientProperties.LoadBalancing

Returns:

the expiration interval.

setPartitionOwnershipExpirationInterval

public void setPartitionOwnershipExpirationInterval(Duration partitionOwnershipExpirationInterval)

Set the partition ownership expiration interval.

Parameters:

partitionOwnershipExpirationInterval - the partition ownership expiration interval.