Package | Description |
---|---|
org.springframework.cloud.gcp.pubsub.core |
Core support for Pub/Sub in Spring.
|
org.springframework.cloud.gcp.pubsub.core.subscriber |
Operations and template for subscribing in Spring Cloud GCP Pub/Sub.
|
org.springframework.cloud.gcp.pubsub.integration.inbound |
Inbound support classes for Spring Integration support in Spring Cloud GCP Pub/Sub.
|
org.springframework.cloud.gcp.pubsub.reactive |
Modifier and Type | Interface and Description |
---|---|
interface |
PubSubOperations
An abstraction for Google Cloud Pub/Sub for publish and subscribe / pull methods.
|
Modifier and Type | Class and Description |
---|---|
class |
PubSubTemplate
Default implementation of
PubSubOperations . |
Modifier and Type | Class and Description |
---|---|
class |
PubSubSubscriberTemplate
Default implementation of
PubSubSubscriberOperations . |
Constructor and Description |
---|
PubSubInboundChannelAdapter(PubSubSubscriberOperations pubSubSubscriberOperations,
String subscriptionName) |
PubSubMessageSource(PubSubSubscriberOperations pubSubSubscriberOperations,
String subscriptionName) |
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.
|
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.