Package io.micronaut.gcp.pubsub.configuration

Class PubSubConfigurationProperties

java.lang.Object

io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties

@ConfigurationProperties("gcp.pubsub")
public class PubSubConfigurationProperties
extends Object

Configuration properties for PubSub support.

Since:

2.0.0

Author:

Vinicius Carvalho

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PREFIX

Constructor Summary

Constructors

Constructor	Description
PubSubConfigurationProperties()

Method Summary

Modifier and Type	Method	Description
int	getKeepAliveIntervalMinutes()	How often to ping the server to keep the channel alive.
String	getPublishingExecutor()
String	getSubscribingExecutor()
String	getTopicEndpoint()	Which endpoint the Publisher should publish messages to.
void	setKeepAliveIntervalMinutes(int keepAliveIntervalMinutes)	How often to ping the server to keep the channel alive.
void	setPublishingExecutor(String publishingExecutor)
void	setSubscribingExecutor(String subscribingExecutor)
void	setTopicEndpoint(String topicEndpoint)

Methods inherited from class java.lang.Object

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

Field Details

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

Constructor Details

PubSubConfigurationProperties

public PubSubConfigurationProperties()

Method Details

getPublishingExecutor

public String getPublishingExecutor()

Returns:

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

setPublishingExecutor

public void setPublishingExecutor(String publishingExecutor)

Parameters:

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

getSubscribingExecutor

public String getSubscribingExecutor()

Returns:

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

setSubscribingExecutor

public void setSubscribingExecutor(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 -

getTopicEndpoint

public String getTopicEndpoint()

Which endpoint the Publisher should publish messages to. Defaults to the global endpoint

Returns:

endpoint

setTopicEndpoint

public void setTopicEndpoint(String topicEndpoint)

Parameters:

topicEndpoint - to be used by all Publisher instances. Default: "" (i.e. the global endpoint)