Uses of Interface
com.google.cloud.spring.pubsub.support.AcknowledgeablePubsubMessage
Packages that use 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
Methods in com.google.cloud.spring.pubsub.core that return types with arguments of type AcknowledgeablePubsubMessageModifier and TypeMethodDescriptionMethod parameters in com.google.cloud.spring.pubsub.core with type arguments of type AcknowledgeablePubsubMessageModifier 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
Methods in com.google.cloud.spring.pubsub.core.subscriber that return types with arguments of type AcknowledgeablePubsubMessageModifier 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) Method parameters in com.google.cloud.spring.pubsub.core.subscriber with type arguments of type AcknowledgeablePubsubMessageModifier 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
Constructors in com.google.cloud.spring.pubsub.integration.inbound with parameters of type AcknowledgeablePubsubMessageModifierConstructorDescriptionPubSubAcknowledgmentCallback
(AcknowledgeablePubsubMessage message, AckMode ackMode) Instantiates a callback for a given message and acknowledgement mode. -
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.reactive
Methods in com.google.cloud.spring.pubsub.reactive that return types with arguments of type AcknowledgeablePubsubMessageModifier and TypeMethodDescriptionreactor.core.publisher.Flux<AcknowledgeablePubsubMessage>
Create an infinite streamFlux
ofAcknowledgeablePubsubMessage
objects. -
Uses of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.support.converter
Subinterfaces of AcknowledgeablePubsubMessage in com.google.cloud.spring.pubsub.support.converterModifier and TypeInterfaceDescriptioninterface
AnAcknowledgeablePubsubMessage
that also contains the payload of the Pub/Sub message converted to the desired typeT
.