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.support |
Supporting classes for handling messages in Spring Cloud GCP Pub/Sub.
|
com.google.cloud.spring.pubsub.support.converter |
Classes related to converting messages in Spring Cloud GCP Pub/Sub.
|
Modifier and Type | Method and Description |
---|---|
Subscriber |
PubSubTemplate.subscribe(String subscription,
Consumer<BasicAcknowledgeablePubsubMessage> messageConsumer) |
Modifier and Type | Method and Description |
---|---|
Subscriber |
PubSubSubscriberOperations.subscribe(String subscription,
Consumer<BasicAcknowledgeablePubsubMessage> messageConsumer)
Add a callback method to an existing subscription.
|
Subscriber |
PubSubSubscriberTemplate.subscribe(String subscription,
Consumer<BasicAcknowledgeablePubsubMessage> messageConsumer) |
Modifier and Type | Interface and Description |
---|---|
interface |
AcknowledgeablePubsubMessage
An extension of
BasicAcknowledgeablePubsubMessage that exposes ack ID and subscription name of the message. |
Modifier and Type | Method and Description |
---|---|
static Optional<BasicAcknowledgeablePubsubMessage> |
GcpPubSubHeaders.getOriginalMessage(org.springframework.messaging.Message<?> message)
A simple utility method for pulling the
GcpPubSubHeaders.ORIGINAL_MESSAGE header out of a Message . |
Modifier and Type | Interface and Description |
---|---|
interface |
ConvertedAcknowledgeablePubsubMessage<T>
An
AcknowledgeablePubsubMessage that also contains the payload of the Pub/Sub
message converted to the desired type T . |
interface |
ConvertedBasicAcknowledgeablePubsubMessage<T>
A
BasicAcknowledgeablePubsubMessage that also contains the payload of the
Pub/Sub message converted to the desired type T . |
Copyright © 2021. All rights reserved.