-
Notifications
You must be signed in to change notification settings - Fork 1.1k
delete pull-related methods from PubSub #1487
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
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. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
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