-
Notifications
You must be signed in to change notification settings - Fork 1.1k
New issue
Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? # to your account
delete pull-related methods from PubSub #1487
Conversation
Instead, provide a way to create the Subscriber object.
return modifyAckDeadlineAsync(subscription, 0, TimeUnit.SECONDS, ackIds); | ||
} | ||
|
||
@Override | ||
public void modifyAckDeadline(String subscription, int deadline, TimeUnit unit, String ackId, |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
.maxQueuedCallbacks(MAX_QUEUED_CALLBACKS.getInteger(optionMap)) | ||
.executorFactory(EXECUTOR_FACTORY.getExecutorFactory(optionMap)) | ||
public Subscriber subscriber(SubscriptionInfo subscription, Subscriber.MessageReceiver receiver) { | ||
// TODO(pongad): Provide a way to pass in the rest of the options. |
Changes Unknown when pulling 9df40ba on pongad:del-pull into ** on GoogleCloudPlatform:pubsub-hp**. |
@davidtorres PTAL |
Changes Unknown when pulling 2239a50 on pongad:del-pull into ** on GoogleCloudPlatform:pubsub-hp**. |
Changes Unknown when pulling 2239a50 on pongad:del-pull into ** on GoogleCloudPlatform:pubsub-hp**. |
A couple high-level things:
|
|
Add a TODO to settle the issue of executors & channels. Otherwise LGTM. |
Changes Unknown when pulling 6cd3804 on pongad:del-pull into ** on GoogleCloudPlatform:pubsub-hp**. |
Changes Unknown when pulling 46bf12f on pongad:del-pull into ** on GoogleCloudPlatform:pubsub-hp**. |
Instead, provide a way to create the Subscriber object.
cc @davidtorres