| Package | Description |
|---|---|
| com.google.cloud.pubsub |
A client to Google Cloud Pub/Sub.
|
| Modifier and Type | Method and Description |
|---|---|
static PubSub.PullOption |
PubSub.PullOption.executorFactory(GrpcServiceOptions.ExecutorFactory executorFactory)
Returns an option to specify the executor used to execute message processor callbacks.
|
static PubSub.PullOption |
PubSub.PullOption.maxQueuedCallbacks(int maxQueuedCallbacks)
Returns an option to specify the maximum number of messages that can be queued in the message
consumer at any time.
|
| Modifier and Type | Method and Description |
|---|---|
PubSub.MessageConsumer |
Subscription.pullAsync(PubSub.MessageProcessor callback,
PubSub.PullOption... options)
Creates a message consumer that pulls messages from this subscription.
|
PubSub.MessageConsumer |
PubSub.pullAsync(String subscription,
PubSub.MessageProcessor callback,
PubSub.PullOption... options)
Creates a message consumer that pulls messages from the provided subscription.
|
Copyright © 2016 Google. All rights reserved.