{"action":"created","issue":{"url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/issues/919","repository_url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go","labels_url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/issues/919/labels{/name}","comments_url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/issues/919/comments","events_url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/issues/919/events","html_url":"https://github.com/GoogleCloudPlatform/google-cloud-go/issues/919","id":303239328,"number":919,"title":"PubSub subscription.Receive stops receiving messages","user":{"login":"ChrisBartonLC","id":31261535,"avatar_url":"https://avatars0.githubusercontent.com/u/31261535?v=4","gravatar_id":"","url":"https://api.github.com/users/ChrisBartonLC","html_url":"https://github.com/ChrisBartonLC","followers_url":"https://api.github.com/users/ChrisBartonLC/followers","following_url":"https://api.github.com/users/ChrisBartonLC/following{/other_user}","gists_url":"https://api.github.com/users/ChrisBartonLC/gists{/gist_id}","starred_url":"https://api.github.com/users/ChrisBartonLC/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ChrisBartonLC/subscriptions","organizations_url":"https://api.github.com/users/ChrisBartonLC/orgs","repos_url":"https://api.github.com/users/ChrisBartonLC/repos","events_url":"https://api.github.com/users/ChrisBartonLC/events{/privacy}","received_events_url":"https://api.github.com/users/ChrisBartonLC/received_events","type":"User","site_admin":false},"labels":[{"id":217652843,"url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/labels/api:%20pubsub","name":"api: pubsub","color":"f8f8f8","default":false},{"id":561680216,"url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/labels/priority:%20p1","name":"priority: p1","color":"ffa03e","default":false},{"id":98312214,"url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/labels/type:%20bug","name":"type: bug","color":"db4437","default":false}],"state":"open","locked":false,"assignee":{"login":"jba","id":18483045,"avatar_url":"https://avatars1.githubusercontent.com/u/18483045?v=4","gravatar_id":"","url":"https://api.github.com/users/jba","html_url":"https://github.com/jba","followers_url":"https://api.github.com/users/jba/followers","following_url":"https://api.github.com/users/jba/following{/other_user}","gists_url":"https://api.github.com/users/jba/gists{/gist_id}","starred_url":"https://api.github.com/users/jba/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jba/subscriptions","organizations_url":"https://api.github.com/users/jba/orgs","repos_url":"https://api.github.com/users/jba/repos","events_url":"https://api.github.com/users/jba/events{/privacy}","received_events_url":"https://api.github.com/users/jba/received_events","type":"User","site_admin":false},"assignees":[{"login":"jba","id":18483045,"avatar_url":"https://avatars1.githubusercontent.com/u/18483045?v=4","gravatar_id":"","url":"https://api.github.com/users/jba","html_url":"https://github.com/jba","followers_url":"https://api.github.com/users/jba/followers","following_url":"https://api.github.com/users/jba/following{/other_user}","gists_url":"https://api.github.com/users/jba/gists{/gist_id}","starred_url":"https://api.github.com/users/jba/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jba/subscriptions","organizations_url":"https://api.github.com/users/jba/orgs","repos_url":"https://api.github.com/users/jba/repos","events_url":"https://api.github.com/users/jba/events{/privacy}","received_events_url":"https://api.github.com/users/jba/received_events","type":"User","site_admin":false}],"milestone":null,"comments":35,"created_at":"2018-03-07T20:00:23Z","updated_at":"2018-03-14T05:06:05Z","closed_at":null,"author_association":"NONE","body":"Hi, we are having a problem where one of our subscriptions stops receiving messages with no errors reported. Other subscriptions in the same app continue to work but these are not heavily used. Is there anyway to debug the issue? We are considering adding a scheduled closing of the PubSub client and re-creating it as a workaround. We are using v0.19.0. Thanks in advance for any advice"},"comment":{"url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/issues/comments/372905893","html_url":"https://github.com/GoogleCloudPlatform/google-cloud-go/issues/919#issuecomment-372905893","issue_url":"https://api.github.com/repos/GoogleCloudPlatform/google-cloud-go/issues/919","id":372905893,"user":{"login":"ChrisBartonLC","id":31261535,"avatar_url":"https://avatars0.githubusercontent.com/u/31261535?v=4","gravatar_id":"","url":"https://api.github.com/users/ChrisBartonLC","html_url":"https://github.com/ChrisBartonLC","followers_url":"https://api.github.com/users/ChrisBartonLC/followers","following_url":"https://api.github.com/users/ChrisBartonLC/following{/other_user}","gists_url":"https://api.github.com/users/ChrisBartonLC/gists{/gist_id}","starred_url":"https://api.github.com/users/ChrisBartonLC/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ChrisBartonLC/subscriptions","organizations_url":"https://api.github.com/users/ChrisBartonLC/orgs","repos_url":"https://api.github.com/users/ChrisBartonLC/repos","events_url":"https://api.github.com/users/ChrisBartonLC/events{/privacy}","received_events_url":"https://api.github.com/users/ChrisBartonLC/received_events","type":"User","site_admin":false},"created_at":"2018-03-14T05:06:05Z","updated_at":"2018-03-14T05:06:05Z","author_association":"NONE","body":"Our code is basically:\r\n\r\n    pusubClient.CreateSubscription(...\r\n    ...\r\n    subscription.ReceiveSettings.MaxExtension = 0\r\n    subscription.ReceiveSettings.MaxOutstandingMessages = -1\r\n    ...\r\n    \tflowControl := semaphore.NewWeighted(int64(ConcurrentMsgCount))\r\n\r\n\tif err := l.subscription.Receive(...) {\r\n\t\tctx := context.WithValue(ctxMsg, share_context.CorrelationIDContextKey, uuid.New().String())\r\n\r\n\t\tif err := flowControl.Acquire(ctx, 1); err != nil {\r\n\t\t\tlog.Logger.Error(ctx, \"Failed acquiring flow control\", log.Logger.FmtError(err))\r\n\t\t}\r\n\t\tdefer flowControl.Release(1)\r\n                ...\r\n\r\n"}}
{"actor":{"display_login":"ChrisBartonLC"}}