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.
|
Modifier and Type | Method and Description |
---|---|
<T> List<ConvertedAcknowledgeablePubsubMessage<T>> |
PubSubTemplate.pullAndConvert(String subscription,
Integer maxMessages,
Boolean returnImmediately,
Class<T> payloadType) |
<T> org.springframework.util.concurrent.ListenableFuture<List<ConvertedAcknowledgeablePubsubMessage<T>>> |
PubSubTemplate.pullAndConvertAsync(String subscription,
Integer maxMessages,
Boolean returnImmediately,
Class<T> payloadType) |
Modifier and Type | Method and Description |
---|---|
<T> List<ConvertedAcknowledgeablePubsubMessage<T>> |
PubSubSubscriberOperations.pullAndConvert(String subscription,
Integer maxMessages,
Boolean returnImmediately,
Class<T> payloadType)
Pull a number of messages from a Google Cloud Pub/Sub subscription and convert them to Spring messages with
the desired payload type.
|
<T> List<ConvertedAcknowledgeablePubsubMessage<T>> |
PubSubSubscriberTemplate.pullAndConvert(String subscription,
Integer maxMessages,
Boolean returnImmediately,
Class<T> payloadType) |
<T> org.springframework.util.concurrent.ListenableFuture<List<ConvertedAcknowledgeablePubsubMessage<T>>> |
PubSubSubscriberOperations.pullAndConvertAsync(String subscription,
Integer maxMessages,
Boolean returnImmediately,
Class<T> payloadType)
Asynchronously pull a number of messages from a Google Cloud Pub/Sub subscription and convert them to Spring messages with
the desired payload type.
|
<T> org.springframework.util.concurrent.ListenableFuture<List<ConvertedAcknowledgeablePubsubMessage<T>>> |
PubSubSubscriberTemplate.pullAndConvertAsync(String subscription,
Integer maxMessages,
Boolean returnImmediately,
Class<T> payloadType) |
Copyright © 2021. All rights reserved.