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
-
Method Summary
Modifier and TypeMethodDescriptionSupplies credentials configuration.int
void
setEmulatorHost
(String emulatorHost) Set the emulator host.void
setKeepAliveIntervalMinutes
(int keepAliveIntervalMinutes) void
setProjectId
(String projectId) Methods inherited from class com.google.cloud.spring.pubsub.core.PubSubConfiguration
computeMaxAckExtensionPeriod, computeMaxDurationPerAckExtension, computeMinDurationPerAckExtension, computeParallelPullCount, computePullEndpoint, computeRetryableCodes, computeSubscriberFlowControlSettings, computeSubscriberRetrySettings, getFullyQualifiedSubscriberProperties, getHealth, getPublisher, getSubscriber, getSubscriptionProperties, initialize, setSubscription
-
Constructor Details
-
GcpPubSubProperties
public GcpPubSubProperties()
-
-
Method Details
-
getProjectId
-
setProjectId
-
getCredentials
Description copied from interface:CredentialsSupplier
Supplies credentials configuration.- Specified by:
getCredentials
in 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)
-