Package io.micronaut.gcp.pubsub.configuration

Class PublisherConfigurationProperties

java.lang.Object

io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties

@EachProperty("gcp.pubsub.publisher")
public class PublisherConfigurationProperties
extends Object

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

Since:

2.0.0

Author:

Vinicius Carvalho, James Kleeh

Constructor Summary

Constructors

Constructor	Description
PublisherConfigurationProperties(String name)

Method Summary

Modifier and Type	Method	Description
com.google.api.gax.batching.BatchingSettings.Builder	getBatchingSettings()	Controls message publishing batch.
String	getExecutor()
com.google.api.gax.batching.FlowControlSettings.Builder	getFlowControlSettings()	Flow Control settings.
String	getName()
com.google.api.gax.retrying.RetrySettings.Builder	getRetrySettings()	Retry policies.
void	setBatchingSettings(com.google.api.gax.batching.BatchingSettings.Builder batchingSettings)	Controls message publishing batch.
void	setExecutor(String executor)
void	setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings.Builder flowControlSettings)	Flow Control settings.
void	setRetrySettings(com.google.api.gax.retrying.RetrySettings.Builder retrySettings)	Retry policies.

Methods inherited from class java.lang.Object

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

Constructor Details

PublisherConfigurationProperties

public PublisherConfigurationProperties(@Parameter
 String name)

Method Details

getRetrySettings

public com.google.api.gax.retrying.RetrySettings.Builder getRetrySettings()

Retry policies.

Returns:

the retry settings

setRetrySettings

public void setRetrySettings(com.google.api.gax.retrying.RetrySettings.Builder retrySettings)

Retry policies.

Parameters:

retrySettings - retry settings

getBatchingSettings

public com.google.api.gax.batching.BatchingSettings.Builder getBatchingSettings()

Controls message publishing batch.

Returns:

batchSettings

setBatchingSettings

public void setBatchingSettings(com.google.api.gax.batching.BatchingSettings.Builder batchingSettings)

Controls message publishing batch.

Parameters:

batchingSettings - batchingSettings

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

getName

public String getName()

Returns:

the name of this configuration

getExecutor

public String getExecutor()

Returns:

executor name

setExecutor

public void setExecutor(String executor)

Parameters:

executor - name to be set