io.micronaut.gcp.pubsub.configuration

Class SubscriberConfigurationProperties

java.lang.Object

io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties

@EachProperty(value="gcp.pubsub.subscriber")
public class SubscriberConfigurationProperties
extends java.lang.Object

Configuration properties for PubSub Subscriber. Each topic has its own configuration if set by the user. for example gcp.pubsub.publisher.animals and gcp.pubsub.publisher.cars would define subscribers with different configurations for each Subscription.

Since:

2.0.0

Author:

Vinicius Carvalho

Constructor Summary

Constructors

Constructor and Description
SubscriberConfigurationProperties(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getExecutor()
com.google.api.gax.batching.FlowControlSettings.Builder	getFlowControlSettings() Flow Control settings.
org.threeten.bp.Duration	getMaxAckExtensionPeriod() Set the maximum period a message ack deadline will be extended.
org.threeten.bp.Duration	getMaxDurationPerAckExtension()
java.lang.String	getName()
java.lang.Integer	getParallelPullCount()
void	setExecutor(java.lang.String executor)
void	setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings.Builder flowControlSettings) Flow Control settings.
void	setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod) Set the maximum period a message ack deadline will be extended.
void	setMaxDurationPerAckExtension(org.threeten.bp.Duration maxDurationPerAckExtension) Set the upper bound for a single mod ack extention period.
void	setParallelPullCount(java.lang.Integer parallelPullCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriberConfigurationProperties

public SubscriberConfigurationProperties(@Parameter
                                         java.lang.String name)

Parameters:

name - of this configuration.

Method Detail

getParallelPullCount

public java.lang.Integer getParallelPullCount()

Returns:

number of concurrent pulls

setParallelPullCount

public void setParallelPullCount(java.lang.Integer parallelPullCount)

Parameters:

parallelPullCount - number of concurrent pulls

getMaxAckExtensionPeriod

public org.threeten.bp.Duration getMaxAckExtensionPeriod()

Set the maximum period a message ack deadline will be extended. Defaults to one hour.

Returns:

max ack deadline.

setMaxAckExtensionPeriod

public void setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod)

Set the maximum period a message ack deadline will be extended. Defaults to one hour.

Parameters:

maxAckExtensionPeriod - value

getMaxDurationPerAckExtension

public org.threeten.bp.Duration getMaxDurationPerAckExtension()

Returns:

the maxDurationPerAckExtension

setMaxDurationPerAckExtension

public void setMaxDurationPerAckExtension(org.threeten.bp.Duration maxDurationPerAckExtension)

Set the upper bound for a single mod ack extention period.

The ack deadline will continue to be extended by up to this duration until MaxAckExtensionPeriod is reached. Setting MaxDurationPerAckExtension bounds the maximum amount of time before a mesage re-delivery in the event the Subscriber fails to extend the deadline.

MaxDurationPerAckExtension configuration can be disabled by specifying a zero duration.

Parameters:

maxDurationPerAckExtension - value

getName

public java.lang.String getName()

Returns:

the name of the configuration

getExecutor

public java.lang.String getExecutor()

Returns:

executor name

setExecutor

public void setExecutor(java.lang.String executor)

Parameters:

executor - name to be set

getFlowControlSettings

public com.google.api.gax.batching.FlowControlSettings.Builder getFlowControlSettings()

Flow Control settings.

Returns:

flowControlSettings

setFlowControlSettings

public void setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings.Builder flowControlSettings)

Flow Control settings.

Parameters:

flowControlSettings - flow control settings