io.micronaut.gcp.pubsub.configuration

Class PubSubConfigurationProperties

java.lang.Object

io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties

@ConfigurationProperties(value="gcp.pubsub")
public class PubSubConfigurationProperties
extends java.lang.Object

Configuration properties for PubSub support.

Since:

2.0.0

Author:

Vinicius Carvalho

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PREFIX

Constructor Summary

Constructors

Constructor and Description
PubSubConfigurationProperties()

Method Summary

Modifier and Type	Method and Description
int	getKeepAliveIntervalMinutes() How often to ping the server to keep the channel alive.
java.lang.String	getPublishingExecutor()
java.lang.String	getSubscribingExecutor()
void	setKeepAliveIntervalMinutes(int keepAliveIntervalMinutes) How often to ping the server to keep the channel alive.
void	setPublishingExecutor(java.lang.String publishingExecutor)
void	setSubscribingExecutor(java.lang.String subscribingExecutor)

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final java.lang.String PREFIX

See Also:

Constant Field Values

Constructor Detail

PubSubConfigurationProperties

public PubSubConfigurationProperties()

Method Detail

getPublishingExecutor

public java.lang.String getPublishingExecutor()

Returns:

the name of the ScheduledExecutorService to be used by all Publisher instances. Default: "scheduled"

setPublishingExecutor

public void setPublishingExecutor(java.lang.String publishingExecutor)

Parameters:

publishingExecutor - Name of the ScheduledExecutorService to be used by all Publisher instances. Default: "scheduled"

getSubscribingExecutor

public java.lang.String getSubscribingExecutor()

Returns:

the name of the ScheduledExecutorService to be used by all Subscriber instances. Default: "scheduled" Defaults to "scheduled"

setSubscribingExecutor

public void setSubscribingExecutor(java.lang.String subscribingExecutor)

Parameters:

subscribingExecutor - Name of the ScheduledExecutorService to be used by all Subscriber instances. Default: "scheduled"

getKeepAliveIntervalMinutes

public int getKeepAliveIntervalMinutes()

How often to ping the server to keep the channel alive. Defaults to 5 minutes.

Returns:

interval

setKeepAliveIntervalMinutes

public void setKeepAliveIntervalMinutes(int keepAliveIntervalMinutes)

How often to ping the server to keep the channel alive. Default: 5 minutes.

Parameters:

keepAliveIntervalMinutes -