Uses of Interface
com.google.cloud.spring.pubsub.core.subscriber.PubSubSubscriberOperations
Packages that use PubSubSubscriberOperations
Package
Description
Core support for Pub/Sub in Spring.
Operations and template for subscribing in Spring Cloud GCP Pub/Sub.
Inbound support classes for Spring Integration support in Spring Cloud GCP Pub/Sub.
-
Uses of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.core
Subinterfaces of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.coreModifier and TypeInterfaceDescriptioninterface
An abstraction for Google Cloud Pub/Sub for publish and subscribe / pull methods.Classes in com.google.cloud.spring.pubsub.core that implement PubSubSubscriberOperations -
Uses of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.core.subscriber
Classes in com.google.cloud.spring.pubsub.core.subscriber that implement PubSubSubscriberOperations -
Uses of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.integration.inbound
Constructors in com.google.cloud.spring.pubsub.integration.inbound with parameters of type PubSubSubscriberOperationsModifierConstructorDescriptionPubSubInboundChannelAdapter
(PubSubSubscriberOperations pubSubSubscriberOperations, String subscriptionName) Instantiates a streaming Pub/Sub subscription adapter.PubSubMessageSource
(PubSubSubscriberOperations pubSubSubscriberOperations, String subscriptionName) Instantiates a Pub/Sub inbound message adapter to poll a given subscription for messages. -
Uses of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.reactive
Constructors in com.google.cloud.spring.pubsub.reactive with parameters of type PubSubSubscriberOperationsModifierConstructorDescriptionPubSubReactiveFactory
(PubSubSubscriberOperations subscriberOperations, reactor.core.scheduler.Scheduler scheduler) Instantiate `PubSubReactiveFactory` capable of generating subscription-based streams.PubSubReactiveFactory
(PubSubSubscriberOperations subscriberOperations, reactor.core.scheduler.Scheduler scheduler, int maxMessages) Instantiate `PubSubReactiveFactory` capable of generating subscription-based streams.