{"action":"created","issue":{"url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/issues/54","repository_url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka","labels_url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/issues/54/labels{/name}","comments_url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/issues/54/comments","events_url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/issues/54/events","html_url":"https://github.com/openwhisk/openwhisk-package-kafka/pull/54","id":189142057,"number":54,"title":"Actively monitor consumers - attempt to heal sick ones individually","user":{"login":"bjustin-ibm","id":7012682,"avatar_url":"https://avatars.githubusercontent.com/u/7012682?v=3","gravatar_id":"","url":"https://api.github.com/users/bjustin-ibm","html_url":"https://github.com/bjustin-ibm","followers_url":"https://api.github.com/users/bjustin-ibm/followers","following_url":"https://api.github.com/users/bjustin-ibm/following{/other_user}","gists_url":"https://api.github.com/users/bjustin-ibm/gists{/gist_id}","starred_url":"https://api.github.com/users/bjustin-ibm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/bjustin-ibm/subscriptions","organizations_url":"https://api.github.com/users/bjustin-ibm/orgs","repos_url":"https://api.github.com/users/bjustin-ibm/repos","events_url":"https://api.github.com/users/bjustin-ibm/events{/privacy}","received_events_url":"https://api.github.com/users/bjustin-ibm/received_events","type":"User","site_admin":false},"labels":[{"id":473047621,"url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/labels/review","name":"review","color":"fbca04","default":false}],"state":"open","locked":false,"assignee":{"login":"dubeejw","id":11520887,"avatar_url":"https://avatars.githubusercontent.com/u/11520887?v=3","gravatar_id":"","url":"https://api.github.com/users/dubeejw","html_url":"https://github.com/dubeejw","followers_url":"https://api.github.com/users/dubeejw/followers","following_url":"https://api.github.com/users/dubeejw/following{/other_user}","gists_url":"https://api.github.com/users/dubeejw/gists{/gist_id}","starred_url":"https://api.github.com/users/dubeejw/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dubeejw/subscriptions","organizations_url":"https://api.github.com/users/dubeejw/orgs","repos_url":"https://api.github.com/users/dubeejw/repos","events_url":"https://api.github.com/users/dubeejw/events{/privacy}","received_events_url":"https://api.github.com/users/dubeejw/received_events","type":"User","site_admin":false},"assignees":[{"login":"dubeejw","id":11520887,"avatar_url":"https://avatars.githubusercontent.com/u/11520887?v=3","gravatar_id":"","url":"https://api.github.com/users/dubeejw","html_url":"https://github.com/dubeejw","followers_url":"https://api.github.com/users/dubeejw/followers","following_url":"https://api.github.com/users/dubeejw/following{/other_user}","gists_url":"https://api.github.com/users/dubeejw/gists{/gist_id}","starred_url":"https://api.github.com/users/dubeejw/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dubeejw/subscriptions","organizations_url":"https://api.github.com/users/dubeejw/orgs","repos_url":"https://api.github.com/users/dubeejw/repos","events_url":"https://api.github.com/users/dubeejw/events{/privacy}","received_events_url":"https://api.github.com/users/dubeejw/received_events","type":"User","site_admin":false}],"milestone":null,"comments":1,"created_at":"2016-11-14T15:31:06Z","updated_at":"2016-11-14T22:07:19Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/pulls/54","html_url":"https://github.com/openwhisk/openwhisk-package-kafka/pull/54","diff_url":"https://github.com/openwhisk/openwhisk-package-kafka/pull/54.diff","patch_url":"https://github.com/openwhisk/openwhisk-package-kafka/pull/54.patch"},"body":"Implement the \"doctor\" thread which monitors all consumers and attempts to heal their sickness by restarting them.\r\n\r\nThis is a pretty big change...\r\n\r\nConsumers no longer _are_ Threads, but rather contain a ConsumerThread field. This allows the Consumer to separately monitor and replace the Thread doing the actual work. The Doctor wakes up every so often, monitors each of the Consumers and checks their health (is their actual state consistent with their desired state). If a Consumer is found to be sick, the Doctor attempts to restart that Consumer individually.\r\n\r\nResolves #46 as well as providing a buffer for messaging system instability."},"comment":{"url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/issues/comments/260478801","html_url":"https://github.com/openwhisk/openwhisk-package-kafka/pull/54#issuecomment-260478801","issue_url":"https://api.github.com/repos/openwhisk/openwhisk-package-kafka/issues/54","id":260478801,"user":{"login":"dubeejw","id":11520887,"avatar_url":"https://avatars.githubusercontent.com/u/11520887?v=3","gravatar_id":"","url":"https://api.github.com/users/dubeejw","html_url":"https://github.com/dubeejw","followers_url":"https://api.github.com/users/dubeejw/followers","following_url":"https://api.github.com/users/dubeejw/following{/other_user}","gists_url":"https://api.github.com/users/dubeejw/gists{/gist_id}","starred_url":"https://api.github.com/users/dubeejw/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dubeejw/subscriptions","organizations_url":"https://api.github.com/users/dubeejw/orgs","repos_url":"https://api.github.com/users/dubeejw/repos","events_url":"https://api.github.com/users/dubeejw/events{/privacy}","received_events_url":"https://api.github.com/users/dubeejw/received_events","type":"User","site_admin":false},"created_at":"2016-11-14T22:07:19Z","updated_at":"2016-11-14T22:07:19Z","body":"ERROR:root:[/.../messageHubTrigger] Uncaught exception: class State has no attribute 'Restarted'\r\n"}}
{"actor":{"display_login":"dubeejw"}}