Class GcpPubSubProperties
java.lang.Object
com.google.cloud.spring.pubsub.core.PubSubConfiguration
com.google.cloud.spring.autoconfigure.pubsub.GcpPubSubProperties
- All Implemented Interfaces:
CredentialsSupplier
@ConfigurationProperties("spring.cloud.gcp.pubsub")
public class GcpPubSubProperties
extends PubSubConfiguration
implements CredentialsSupplier
Properties for Pub/Sub.
-
Nested Class Summary
Nested classes/interfaces inherited from class com.google.cloud.spring.pubsub.core.PubSubConfiguration
PubSubConfiguration.Batching, PubSubConfiguration.FlowControl, PubSubConfiguration.Health, PubSubConfiguration.Publisher, PubSubConfiguration.Retry, PubSubConfiguration.Subscriber -
Field Summary
Fields inherited from class com.google.cloud.spring.pubsub.core.PubSubConfiguration
DEFAULT_EXECUTOR_THREADS -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionSupplies credentials configuration.intvoidsetEmulatorHost(String emulatorHost) Set the emulator host.voidsetKeepAliveIntervalMinutes(int keepAliveIntervalMinutes) voidsetProjectId(String projectId) Methods inherited from class com.google.cloud.spring.pubsub.core.PubSubConfiguration
computeMaxAckExtensionPeriod, computeMaxDurationPerAckExtension, computeMinDurationPerAckExtension, computeParallelPullCount, computePullEndpoint, computeRetryableCodes, computeSubscriberFlowControlSettings, computeSubscriberRetrySettings, computeSubscriberUniverseDomain, getFullyQualifiedSubscriberProperties, getHealth, getPublisher, getSubscriber, getSubscriptionProperties, initialize, setSubscription
-
Constructor Details
-
GcpPubSubProperties
public GcpPubSubProperties()
-
-
Method Details
-
getProjectId
-
setProjectId
-
getCredentials
Description copied from interface:CredentialsSupplierSupplies credentials configuration.- Specified by:
getCredentialsin interfaceCredentialsSupplier- Returns:
- a POJO containing Google Cloud credentials location and scopes
-
getEmulatorHost
-
setEmulatorHost
Set the emulator host.- Parameters:
emulatorHost- the emulator host.
-
getKeepAliveIntervalMinutes
public int getKeepAliveIntervalMinutes() -
setKeepAliveIntervalMinutes
public void setKeepAliveIntervalMinutes(int keepAliveIntervalMinutes)
-