Uses of Interface
com.google.cloud.spring.pubsub.core.subscriber.PubSubSubscriberOperations

Packages that use PubSubSubscriberOperations

Package	Description
com.google.cloud.spring.pubsub.core	Core support for Pub/Sub in Spring.
com.google.cloud.spring.pubsub.core.subscriber	Operations and template for subscribing in Spring Cloud GCP Pub/Sub.
com.google.cloud.spring.pubsub.integration.inbound	Inbound support classes for Spring Integration support in Spring Cloud GCP Pub/Sub.
com.google.cloud.spring.pubsub.reactive

Uses of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.core

Subinterfaces of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.core

Modifier and Type	Interface and Description
interface	PubSubOperations An abstraction for Google Cloud Pub/Sub for publish and subscribe / pull methods.

Classes in com.google.cloud.spring.pubsub.core that implement PubSubSubscriberOperations

Modifier and Type	Class and Description
class	PubSubTemplate Default implementation of PubSubOperations.

Uses of PubSubSubscriberOperations in com.google.cloud.spring.pubsub.core.subscriber

Classes in com.google.cloud.spring.pubsub.core.subscriber that implement PubSubSubscriberOperations

Modifier and Type	Class and Description
class	PubSubSubscriberTemplate Default implementation of 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 PubSubSubscriberOperations

Constructor and Description
PubSubInboundChannelAdapter(PubSubSubscriberOperations pubSubSubscriberOperations, String subscriptionName) Instantiates a streaming Pub/Sub subscirtion 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 PubSubSubscriberOperations

Constructor and Description
PubSubReactiveFactory(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.