public interface SubscriberFactory
PubSubTemplate
to create
supporting objects for consuming messages from Pub/Sub subscriptions.Modifier and Type | Method and Description |
---|---|
default PubSubAcknowledger |
createAcknowledger()
Create a
PubSubAcknowledger to (negatively) acknowledge messages in bulk. |
com.google.pubsub.v1.PullRequest |
createPullRequest(String subscriptionName,
Integer maxMessages,
Boolean returnImmediately)
Create a
PullRequest for synchronously pulling a number of messages from
a Google Cloud Pub/Sub subscription. |
com.google.cloud.pubsub.v1.Subscriber |
createSubscriber(String subscriptionName,
com.google.cloud.pubsub.v1.MessageReceiver receiver)
Create a
Subscriber for the specified subscription name and wired it up to
asynchronously deliver messages to the provided MessageReceiver . |
com.google.cloud.pubsub.v1.stub.SubscriberStub |
createSubscriberStub()
Create a
SubscriberStub that is needed to execute PullRequest s. |
com.google.cloud.pubsub.v1.Subscriber createSubscriber(String subscriptionName, com.google.cloud.pubsub.v1.MessageReceiver receiver)
Subscriber
for the specified subscription name and wired it up to
asynchronously deliver messages to the provided MessageReceiver
.subscriptionName
- the name of the subscriptionreceiver
- the callback for receiving messages asynchronouslySubscriber
that was created to bind the receiver to the subscriptioncom.google.pubsub.v1.PullRequest createPullRequest(String subscriptionName, Integer maxMessages, Boolean returnImmediately)
PullRequest
for synchronously pulling a number of messages from
a Google Cloud Pub/Sub subscription.subscriptionName
- the name of the subscriptionmaxMessages
- the maximum number of pulled messagesreturnImmediately
- causes the pull request to return immediately even
if subscription doesn't contain enough messages to satisfy maxMessages
SubscriberStub
com.google.cloud.pubsub.v1.stub.SubscriberStub createSubscriberStub()
SubscriberStub
that is needed to execute PullRequest
s.SubscriberStub
used for executing PullRequest
sdefault PubSubAcknowledger createAcknowledger()
PubSubAcknowledger
to (negatively) acknowledge messages in bulk.Copyright © 2018 Pivotal Software, Inc.. All rights reserved.