A C D F G H I J L N O P S T V

A

ack(Collection<AcknowledgeablePubsubMessage>) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Acknowledge a batch of messages.

ack(Collection<AcknowledgeablePubsubMessage>) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

ack() - Method in class org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

ACK_ID - Static variable in class org.springframework.cloud.gcp.pubsub.support.GcpPubSubHeaders

AckMode - Enum in org.springframework.cloud.gcp.pubsub.integration

Determines acknowledgement policy for incoming messages from Google Cloud Pub/Sub.

AcknowledgeablePubsubMessage - Class in org.springframework.cloud.gcp.pubsub.support

A PubsubMessage wrapper that allows it to be acknowledged.

AcknowledgeablePubsubMessage(PubsubMessage, String, String, SubscriberStub) - Constructor for class org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

ACKNOWLEDGEMENT - Static variable in class org.springframework.cloud.gcp.pubsub.support.GcpPubSubHeaders

afterPropertiesSet() - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

C

createPublisher(String) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

createPublisher(String) - Method in interface org.springframework.cloud.gcp.pubsub.support.PublisherFactory

createPullRequest(String, Integer, Boolean) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

createPullRequest(String, Integer, Boolean) - Method in interface org.springframework.cloud.gcp.pubsub.support.SubscriberFactory

Create a PullRequest for synchronously pulling a number of messages from a Google Cloud Pub/Sub subscription.

createSubscriber(String, MessageReceiver) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

createSubscriber(String, MessageReceiver) - Method in interface org.springframework.cloud.gcp.pubsub.support.SubscriberFactory

Create a Subscriber for the specified subscription name and wired it up to asynchronously deliver messages to the provided MessageReceiver.

createSubscriberStub() - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

createSubscriberStub() - Method in interface org.springframework.cloud.gcp.pubsub.support.SubscriberFactory

Create a SubscriberStub that is needed to execute PullRequests.

createSubscription(String, String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Create a new subscription on Google Cloud Pub/Sub.

createSubscription(String, String, Integer) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Create a new subscription on Google Cloud Pub/Sub.

createSubscription(String, String, String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Create a new subscription on Google Cloud Pub/Sub.

createSubscription(String, String, Integer, String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Create a new subscription on Google Cloud Pub/Sub.

createTopic(String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Create a new topic on Google Cloud Pub/Sub.

D

DefaultPublisherFactory - Class in org.springframework.cloud.gcp.pubsub.support

The default PublisherFactory implementation.

DefaultPublisherFactory(GcpProjectIdProvider) - Constructor for class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Create DefaultPublisherFactory instance based on the provided GcpProjectIdProvider.

DefaultSubscriberFactory - Class in org.springframework.cloud.gcp.pubsub.support

The default SubscriberFactory implementation.

DefaultSubscriberFactory(GcpProjectIdProvider) - Constructor for class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Default DefaultSubscriberFactory constructor.

deleteSubscription(String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Delete a subscription from Google Cloud Pub/Sub.

deleteTopic(String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Delete a topic from Google Cloud Pub/Sub.

doStart() - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

doStop() - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

F

fromHeaders(MessageHeaders, Map<String, String>) - Method in class org.springframework.cloud.gcp.pubsub.integration.PubSubHeaderMapper

Generate headers in PubsubMessage format from MessageHeaders.

fromPubSubMessage(PubsubMessage, Class<T>) - Method in class org.springframework.cloud.gcp.pubsub.support.converter.JacksonPubSubMessageConverter

fromPubSubMessage(PubsubMessage, Class<T>) - Method in interface org.springframework.cloud.gcp.pubsub.support.converter.PubSubMessageConverter

Convert the payload of a given PubsubMessage to a desired Java type.

fromPubSubMessage(PubsubMessage, Class<T>) - Method in class org.springframework.cloud.gcp.pubsub.support.converter.SimplePubSubMessageConverter

G

GcpPubSubHeaders - Class in org.springframework.cloud.gcp.pubsub.support

Google Cloud Platform internal headers for Spring Messaging messages.

GcpPubSubHeaders() - Constructor for class org.springframework.cloud.gcp.pubsub.support.GcpPubSubHeaders

getAckId() - Method in class org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

getAckMode() - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

getDefaultAckDeadline() - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

getMessageConverter() - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

getPayloadType() - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

getPublishCallback() - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

getPublisherFactory() - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

getPublishTimeoutExpression() - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

getPubsubMessage() - Method in class org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

getSubscriberFactory() - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

getSubscription(String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Get the configuration of a Google Cloud Pub/Sub subscription.

getSubscriptionName() - Method in class org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

getTopic(String) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Get the configuration of a Google Cloud Pub/Sub topic.

getTopicExpression() - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

H

handleMessageInternal(Message<?>) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

I

isSync() - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

J

JacksonPubSubMessageConverter - Class in org.springframework.cloud.gcp.pubsub.support.converter

A converter using Jackson JSON.

JacksonPubSubMessageConverter(ObjectMapper) - Constructor for class org.springframework.cloud.gcp.pubsub.support.converter.JacksonPubSubMessageConverter

Constructor

L

listSubscriptions() - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Return every subscription in a project.

listTopics() - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Return every topic in a project.

N

nack(Collection<AcknowledgeablePubsubMessage>) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Negatively acknowledge a batch of messages.

nack(Collection<AcknowledgeablePubsubMessage>) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

nack() - Method in class org.springframework.cloud.gcp.pubsub.support.AcknowledgeablePubsubMessage

O

onInit() - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

org.springframework.cloud.gcp.pubsub - package org.springframework.cloud.gcp.pubsub

org.springframework.cloud.gcp.pubsub.core - package org.springframework.cloud.gcp.pubsub.core

org.springframework.cloud.gcp.pubsub.integration - package org.springframework.cloud.gcp.pubsub.integration

org.springframework.cloud.gcp.pubsub.integration.inbound - package org.springframework.cloud.gcp.pubsub.integration.inbound

org.springframework.cloud.gcp.pubsub.integration.outbound - package org.springframework.cloud.gcp.pubsub.integration.outbound

org.springframework.cloud.gcp.pubsub.support - package org.springframework.cloud.gcp.pubsub.support

org.springframework.cloud.gcp.pubsub.support.converter - package org.springframework.cloud.gcp.pubsub.support.converter

P

publish(String, T, Map<String, String>) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Send a message to Pub/Sub.

publish(String, T) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Send a message to Pub/Sub.

publish(String, PubsubMessage) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Send a message to Pub/Sub.

publish(String, T, Map<String, String>) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

Uses the configured message converter to first convert the payload and headers to a PubsubMessage and then publish it.

publish(String, T) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

publish(String, PubsubMessage) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

PublisherFactory - Interface in org.springframework.cloud.gcp.pubsub.support

PubSubAdmin - Class in org.springframework.cloud.gcp.pubsub

Pub/Sub admin utility that creates new topics and subscriptions on Google Cloud Pub/Sub.

PubSubAdmin(GcpProjectIdProvider, CredentialsProvider) - Constructor for class org.springframework.cloud.gcp.pubsub.PubSubAdmin

This constructor instantiates TopicAdminClient and SubscriptionAdminClient with all their defaults and the provided credentials provider.

PubSubAdmin(GcpProjectIdProvider, TopicAdminClient, SubscriptionAdminClient) - Constructor for class org.springframework.cloud.gcp.pubsub.PubSubAdmin

PubSubException - Exception in org.springframework.cloud.gcp.pubsub.core

The Spring Google Cloud Pub/Sub specific NestedRuntimeException.

PubSubException(String) - Constructor for exception org.springframework.cloud.gcp.pubsub.core.PubSubException

PubSubException(String, Throwable) - Constructor for exception org.springframework.cloud.gcp.pubsub.core.PubSubException

PubSubHeaderMapper - Class in org.springframework.cloud.gcp.pubsub.integration

Maps headers from PubsubMessages to Messages and vice-versa.

PubSubHeaderMapper() - Constructor for class org.springframework.cloud.gcp.pubsub.integration.PubSubHeaderMapper

PubSubInboundChannelAdapter - Class in org.springframework.cloud.gcp.pubsub.integration.inbound

Converts from GCP Pub/Sub message to Spring message and sends the Spring message to the attached channels.

PubSubInboundChannelAdapter(PubSubTemplate, String) - Constructor for class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

PubSubMessageConversionException - Exception in org.springframework.cloud.gcp.pubsub.support.converter

An exception raised when conversion to or from a PubsubMessage fails.

PubSubMessageConversionException(String) - Constructor for exception org.springframework.cloud.gcp.pubsub.support.converter.PubSubMessageConversionException

PubSubMessageConversionException(String, Throwable) - Constructor for exception org.springframework.cloud.gcp.pubsub.support.converter.PubSubMessageConversionException

PubSubMessageConverter - Interface in org.springframework.cloud.gcp.pubsub.support.converter

Interface for converters that can convert POJOs to and from Pub/Sub messages.

PubSubMessageHandler - Class in org.springframework.cloud.gcp.pubsub.integration.outbound

Outbound channel adapter to publish messages to Google Cloud Pub/Sub.

PubSubMessageHandler(PubSubOperations, String) - Constructor for class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

PubSubOperations - Interface in org.springframework.cloud.gcp.pubsub.core

An abstraction for Google Cloud Pub/Sub.

PubSubTemplate - Class in org.springframework.cloud.gcp.pubsub.core

Default implementation of PubSubOperations.

PubSubTemplate(PublisherFactory, SubscriberFactory) - Constructor for class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

Default PubSubTemplate constructor that uses SimplePubSubMessageConverter to serialize and deserialize payloads.

pull(String, Integer, Boolean) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Pull a number of messages from a Google Cloud Pub/Sub subscription.

pull(String, Integer, Boolean) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

pullAndAck(String, Integer, Boolean) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Pull and auto-acknowledge a number of messages from a Google Cloud Pub/Sub subscription.

pullAndAck(String, Integer, Boolean) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

pullNext(String) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Pull and auto-acknowledge a message from a Google Cloud Pub/Sub subscription.

pullNext(String) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

S

setAckMode(AckMode) - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

setApiClock(ApiClock) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the clock to use for the retry logic in synchronous pulling.

setBatchingSettings(BatchingSettings) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Set the API call batching configuration.

setChannelProvider(TransportChannelProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Set the provider for the channel to be used by the publisher.

setChannelProvider(TransportChannelProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the provider for the subscribers' transport channel.

setCredentialsProvider(CredentialsProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Set the provider for the GCP credentials to be used by the publisher on every API calls it makes.

setCredentialsProvider(CredentialsProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the provider for the GCP credentials to be used by the subscribers' API calls.

setDefaultAckDeadline(int) - Method in class org.springframework.cloud.gcp.pubsub.PubSubAdmin

Set the default acknowledgement deadline value.

setExecutorProvider(ExecutorProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Set the provider for the executor that will be used by the publisher.

setExecutorProvider(ExecutorProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the provider for the subscribers' executor.

setFlowControlSettings(FlowControlSettings) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the flow control for the subscribers, including the behaviour for when the flow limits are hit.

setHeaderMapper(HeaderMapper<Map<String, String>>) - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

Set the header mapper to map headers from incoming PubsubMessage into Message.

setHeaderMapper(HeaderMapper<Map<String, String>>) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the header mapper to map headers from Message into outbound PubsubMessage.

setHeaderProvider(HeaderProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Set the provider for the HTTP headers to be used in the Pub/Sub REST API requests.

setHeaderProvider(HeaderProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the provider for the HTTP headers to be added to the subscribers' REST API calls.

setInboundHeaderPatterns(String...) - Method in class org.springframework.cloud.gcp.pubsub.integration.PubSubHeaderMapper

Set the patterns of the headers to be mapped in PubSubHeaderMapper.toHeaders(Map).

setMaxAckExtensionPeriod(Duration) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the maximum period the ack timeout is extended by.

setMessageConverter(PubSubMessageConverter) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

setOutboundHeaderPatterns(String...) - Method in class org.springframework.cloud.gcp.pubsub.integration.PubSubHeaderMapper

Set the patterns of the headers to be mapped in PubSubHeaderMapper.fromHeaders(MessageHeaders, Map).

setParallelPullCount(Integer) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the number of pull workers.

setPayloadType(Class) - Method in class org.springframework.cloud.gcp.pubsub.integration.inbound.PubSubInboundChannelAdapter

Set the desired type of the payload of the Message constructed by converting the incoming Pub/Sub message.

setPublishCallback(ListenableFutureCallback<String>) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the callback to be activated when the publish call resolves.

setPublishTimeout(long) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub.

setPublishTimeoutExpression(Expression) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the SpEL expression to evaluate a timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub.

setPublishTimeoutExpressionString(String) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the SpEL expression to evaluate a timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub from a string.

setPullEndpoint(String) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the endpoint for synchronous pulling messages.

setRetrySettings(RetrySettings) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultPublisherFactory

Set the API call retry configuration.

setSubscriberStubRetrySettings(RetrySettings) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the retry settings for the generated subscriber stubs.

setSync(boolean) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set publish method to be synchronous or asynchronous.

setSystemExecutorProvider(ExecutorProvider) - Method in class org.springframework.cloud.gcp.pubsub.support.DefaultSubscriberFactory

Set the provider for the system executor, to poll and manage lease extensions.

setTopic(String) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the topic where this adapter sends messages to.

setTopicExpression(Expression) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the SpEL expression for the topic this adapter sends messages to.

setTopicExpressionString(String) - Method in class org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

Set the topic expression string that is evaluated into an actual expression.

SimplePubSubMessageConverter - Class in org.springframework.cloud.gcp.pubsub.support.converter

A simple PubSubMessageConverter that directly maps payloads of type byte[], ByteString, ByteBuffer, and String to Pub/Sub messages.

SimplePubSubMessageConverter() - Constructor for class org.springframework.cloud.gcp.pubsub.support.converter.SimplePubSubMessageConverter

SimplePubSubMessageConverter(Charset) - Constructor for class org.springframework.cloud.gcp.pubsub.support.converter.SimplePubSubMessageConverter

subscribe(String, MessageReceiver) - Method in interface org.springframework.cloud.gcp.pubsub.core.PubSubOperations

Add a callback method to an existing subscription.

subscribe(String, MessageReceiver) - Method in class org.springframework.cloud.gcp.pubsub.core.PubSubTemplate

SubscriberFactory - Interface in org.springframework.cloud.gcp.pubsub.support

Interface used by the PubSubTemplate to create supporting objects for consuming messages from Pub/Sub subscriptions.

SUBSCRIPTION - Static variable in class org.springframework.cloud.gcp.pubsub.support.GcpPubSubHeaders

T

toHeaders(Map<String, String>) - Method in class org.springframework.cloud.gcp.pubsub.integration.PubSubHeaderMapper

Generate headers in Message format from Map<String, String>.

TOPIC - Static variable in class org.springframework.cloud.gcp.pubsub.support.GcpPubSubHeaders

toPubSubMessage(Object, Map<String, String>) - Method in class org.springframework.cloud.gcp.pubsub.support.converter.JacksonPubSubMessageConverter

toPubSubMessage(Object, Map<String, String>) - Method in interface org.springframework.cloud.gcp.pubsub.support.converter.PubSubMessageConverter

Create a PubsubMessage given an object for the payload and a map of headers

toPubSubMessage(Object, Map<String, String>) - Method in class org.springframework.cloud.gcp.pubsub.support.converter.SimplePubSubMessageConverter

V

valueOf(String) - Static method in enum org.springframework.cloud.gcp.pubsub.integration.AckMode

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.springframework.cloud.gcp.pubsub.integration.AckMode

Returns an array containing the constants of this enum type, in the order they are declared.

A C D F G H I J L N O P S T V