Uses of Interface
com.google.cloud.spring.pubsub.support.AcknowledgeablePubsubMessage
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.
Classes related to converting messages in Spring Cloud GCP Pub/Sub.
-
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.core
Modifier and TypeMethodDescriptionModifier and TypeMethodDescriptionPubSubTemplate.ack
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages) PubSubTemplate.modifyAckDeadline
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages, int ackDeadlineSeconds) PubSubTemplate.nack
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages) -
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.core.subscriber
Modifier and TypeMethodDescriptionPubSubSubscriberOperations.pull
(String subscription, Integer maxMessages, Boolean returnImmediately) Pull a number of messages from a Google Cloud Pub/Sub subscription.PubSubSubscriberOperations.pullAsync
(String subscription, Integer maxMessages, Boolean returnImmediately) Asynchronously pull a number of messages from a Google Cloud Pub/Sub subscription.PubSubSubscriberTemplate.pullAsync
(String subscription, Integer maxMessages, Boolean returnImmediately) Modifier and TypeMethodDescriptionPubSubSubscriberOperations.ack
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages) Acknowledge a batch of messages.PubSubSubscriberTemplate.ack
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages) Acknowledge messages in per-subscription batches.PubSubSubscriberOperations.modifyAckDeadline
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages, int ackDeadlineSeconds) Modify the ack deadline of a batch of messages.PubSubSubscriberTemplate.modifyAckDeadline
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages, int ackDeadlineSeconds) Modify multiple messages' ack deadline in per-subscription batches.PubSubSubscriberOperations.nack
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages) Negatively acknowledge a batch of messages.PubSubSubscriberTemplate.nack
(Collection<? extends AcknowledgeablePubsubMessage> acknowledgeablePubsubMessages) Nack messages in per-subscription batches. -
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.integration.inbound
ModifierConstructorDescriptionPubSubAcknowledgmentCallback
(AcknowledgeablePubsubMessage message, AckMode ackMode) Instantiates a callback for a given message and acknowledgement mode. -
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.reactive
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<AcknowledgeablePubsubMessage>
Create an infinite streamFlux
ofAcknowledgeablePubsubMessage
objects. -
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.support.converter
Modifier and TypeInterfaceDescriptioninterface
AnAcknowledgeablePubsubMessage
that also contains the payload of the Pub/Sub message converted to the desired typeT
.