You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I wasn't able to reproduce this locally - @leibale would you mind sharing some example code to help reproduce this error? I believe maxInProgress is a convenience option for the client only, so I'm a little confused on how it's getting sent to the upstream API.
when you create a subscription you can set the interval and stuff like this, but you can't set the maximum of messages your worker will work in parallel.
at version 24 (I think) wee (I create a pull request) add option to set the maxInProgress and the subscription not pull more messages if your worker not call to message.ack or message.skip (this functions do -- to the counter and check if there is more messages).
Activity
stephenplusplus commentedon Dec 2, 2015
Where is that field hiding? I'll find it unless @callmehiphop beats me to it.
leibale commentedon Dec 3, 2015
https://github.com/GoogleCloudPlatform/gcloud-node/blob/master/lib/pubsub/subscription.js#L56
callmehiphop commentedon Dec 3, 2015
I wasn't able to reproduce this locally - @leibale would you mind sharing some example code to help reproduce this error? I believe
maxInProgressis a convenience option for the client only, so I'm a little confused on how it's getting sent to the upstream API.leibale commentedon Dec 3, 2015
when you create a subscription you can set the interval and stuff like this, but you can't set the maximum of messages your worker will work in parallel.
at version 24 (I think) wee (I create a pull request) add option to set the
maxInProgressand the subscription not pull more messages if your worker not call to message.ack or message.skip (this functions do -- to the counter and check if there is more messages).I'm sorry for the English..
docs(samples): removing migrated samples (#985)
docs(samples): removing migrated samples (#985)
feat: GrpcClient.loadProtoJSON to load protobuf.js JSON proto (#985)
Revert "Use Random Number from `crypto` to generate AutoId. (#984)" (#…
chore(main): release 3.9.0 (#985)
chore(main): release 3.9.0 (#985)
chore(main): release 3.9.0 (#985)
chore(main): release 3.9.0 (googleapis#985)