{"action":"created","comment":{"url":"https://api.github.com/repos/weberr13/QueueNado/pulls/comments/38353751","id":38353751,"diff_hunk":"@@ -96,9 +119,36 @@ size_t Notifier::Notify() {\n       LOG(WARNING) << \"Uninitialized notifier queues\";\n       return {0};\n    }\n-   const std::string message = \"notify\";\n-   LOG(INFO) << message;\n-   gQueue->Fire(message);\n+   LOG(INFO) << \"Notifier: Sending notification message: \" << notifyMessage;\n+   gQueue->Fire(notifyMessage);\n+   size_t confirmed = ReceiveConfirmation();\n+   LOG(INFO) << \"Notifier received \" << confirmed << \" handshakes\";\n+   return {confirmed};\n+}\n+\n+/*\n+ * Fire a message from the Shotgun to be\n+ *    read by the queue subscriber. Then wait for listeners\n+ *    to confirm they received the notification\n+ * \n+ * @param vector of strings to be sent to the listeners             \n+ * @return number of confirmed updates\n+ */\n+size_t Notifier::Notify(const std::vector<std::string>& messages) {\n+   std::lock_guard<std::mutex> guard(gLock);\n+   std::vector<std::string> bullets;\n+   bullets.push_back(notifyMessage);\n+\n+   for (auto& msg : messages) {\n+      bullets.push_back(msg);\n+   }\n+\n+   if (QueuesAreUnitialized()) {\n+      LOG(WARNING) << \"Uninitialized notifier queues\";","path":"src/Notifier.cpp","position":77,"original_position":77,"commit_id":"e909ab5764b6ba41379abea5dac0a579b41c425f","original_commit_id":"e909ab5764b6ba41379abea5dac0a579b41c425f","user":{"login":"craig-cogdill","id":10603412,"avatar_url":"https://avatars.githubusercontent.com/u/10603412?v=3","gravatar_id":"","url":"https://api.github.com/users/craig-cogdill","html_url":"https://github.com/craig-cogdill","followers_url":"https://api.github.com/users/craig-cogdill/followers","following_url":"https://api.github.com/users/craig-cogdill/following{/other_user}","gists_url":"https://api.github.com/users/craig-cogdill/gists{/gist_id}","starred_url":"https://api.github.com/users/craig-cogdill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/craig-cogdill/subscriptions","organizations_url":"https://api.github.com/users/craig-cogdill/orgs","repos_url":"https://api.github.com/users/craig-cogdill/repos","events_url":"https://api.github.com/users/craig-cogdill/events{/privacy}","received_events_url":"https://api.github.com/users/craig-cogdill/received_events","type":"User","site_admin":false},"body":"LOG(FATAL)?","created_at":"2015-08-31T20:11:11Z","updated_at":"2015-08-31T20:11:11Z","html_url":"https://github.com/weberr13/QueueNado/pull/19#discussion_r38353751","pull_request_url":"https://api.github.com/repos/weberr13/QueueNado/pulls/19","_links":{"self":{"href":"https://api.github.com/repos/weberr13/QueueNado/pulls/comments/38353751"},"html":{"href":"https://github.com/weberr13/QueueNado/pull/19#discussion_r38353751"},"pull_request":{"href":"https://api.github.com/repos/weberr13/QueueNado/pulls/19"}}},"pull_request":{"url":"https://api.github.com/repos/weberr13/QueueNado/pulls/19","id":43663908,"html_url":"https://github.com/weberr13/QueueNado/pull/19","diff_url":"https://github.com/weberr13/QueueNado/pull/19.diff","patch_url":"https://github.com/weberr13/QueueNado/pull/19.patch","issue_url":"https://api.github.com/repos/weberr13/QueueNado/issues/19","number":19,"state":"open","locked":false,"title":"2.7.1 Use the notifier to send messages","user":{"login":"craig-cogdill","id":10603412,"avatar_url":"https://avatars.githubusercontent.com/u/10603412?v=3","gravatar_id":"","url":"https://api.github.com/users/craig-cogdill","html_url":"https://github.com/craig-cogdill","followers_url":"https://api.github.com/users/craig-cogdill/followers","following_url":"https://api.github.com/users/craig-cogdill/following{/other_user}","gists_url":"https://api.github.com/users/craig-cogdill/gists{/gist_id}","starred_url":"https://api.github.com/users/craig-cogdill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/craig-cogdill/subscriptions","organizations_url":"https://api.github.com/users/craig-cogdill/orgs","repos_url":"https://api.github.com/users/craig-cogdill/repos","events_url":"https://api.github.com/users/craig-cogdill/events{/privacy}","received_events_url":"https://api.github.com/users/craig-cogdill/received_events","type":"User","site_admin":false},"body":"The Notifier can now send the listeners a single string or a vector of strings as well as no explicit message. It is the job of the Listener to check if it received any messages before accessing the data in the member vector","created_at":"2015-08-28T19:36:38Z","updated_at":"2015-08-31T20:11:11Z","closed_at":null,"merged_at":null,"merge_commit_sha":"f59a20386466b47c61ff4a70289b3cbc77419322","assignee":null,"milestone":null,"commits_url":"https://api.github.com/repos/weberr13/QueueNado/pulls/19/commits","review_comments_url":"https://api.github.com/repos/weberr13/QueueNado/pulls/19/comments","review_comment_url":"https://api.github.com/repos/weberr13/QueueNado/pulls/comments{/number}","comments_url":"https://api.github.com/repos/weberr13/QueueNado/issues/19/comments","statuses_url":"https://api.github.com/repos/weberr13/QueueNado/statuses/e909ab5764b6ba41379abea5dac0a579b41c425f","head":{"label":"craig-cogdill:2.7.1__SendABetterMessage","ref":"2.7.1__SendABetterMessage","sha":"e909ab5764b6ba41379abea5dac0a579b41c425f","user":{"login":"craig-cogdill","id":10603412,"avatar_url":"https://avatars.githubusercontent.com/u/10603412?v=3","gravatar_id":"","url":"https://api.github.com/users/craig-cogdill","html_url":"https://github.com/craig-cogdill","followers_url":"https://api.github.com/users/craig-cogdill/followers","following_url":"https://api.github.com/users/craig-cogdill/following{/other_user}","gists_url":"https://api.github.com/users/craig-cogdill/gists{/gist_id}","starred_url":"https://api.github.com/users/craig-cogdill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/craig-cogdill/subscriptions","organizations_url":"https://api.github.com/users/craig-cogdill/orgs","repos_url":"https://api.github.com/users/craig-cogdill/repos","events_url":"https://api.github.com/users/craig-cogdill/events{/privacy}","received_events_url":"https://api.github.com/users/craig-cogdill/received_events","type":"User","site_admin":false},"repo":{"id":30265161,"name":"QueueNado","full_name":"craig-cogdill/QueueNado","owner":{"login":"craig-cogdill","id":10603412,"avatar_url":"https://avatars.githubusercontent.com/u/10603412?v=3","gravatar_id":"","url":"https://api.github.com/users/craig-cogdill","html_url":"https://github.com/craig-cogdill","followers_url":"https://api.github.com/users/craig-cogdill/followers","following_url":"https://api.github.com/users/craig-cogdill/following{/other_user}","gists_url":"https://api.github.com/users/craig-cogdill/gists{/gist_id}","starred_url":"https://api.github.com/users/craig-cogdill/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/craig-cogdill/subscriptions","organizations_url":"https://api.github.com/users/craig-cogdill/orgs","repos_url":"https://api.github.com/users/craig-cogdill/repos","events_url":"https://api.github.com/users/craig-cogdill/events{/privacy}","received_events_url":"https://api.github.com/users/craig-cogdill/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/craig-cogdill/QueueNado","description":"Implementation of fast queue patterns (Push/Pull, request/reply, pub/sub, dealer/router) for C++","fork":true,"url":"https://api.github.com/repos/craig-cogdill/QueueNado","forks_url":"https://api.github.com/repos/craig-cogdill/QueueNado/forks","keys_url":"https://api.github.com/repos/craig-cogdill/QueueNado/keys{/key_id}","collaborators_url":"https://api.github.com/repos/craig-cogdill/QueueNado/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/craig-cogdill/QueueNado/teams","hooks_url":"https://api.github.com/repos/craig-cogdill/QueueNado/hooks","issue_events_url":"https://api.github.com/repos/craig-cogdill/QueueNado/issues/events{/number}","events_url":"https://api.github.com/repos/craig-cogdill/QueueNado/events","assignees_url":"https://api.github.com/repos/craig-cogdill/QueueNado/assignees{/user}","branches_url":"https://api.github.com/repos/craig-cogdill/QueueNado/branches{/branch}","tags_url":"https://api.github.com/repos/craig-cogdill/QueueNado/tags","blobs_url":"https://api.github.com/repos/craig-cogdill/QueueNado/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/craig-cogdill/QueueNado/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/craig-cogdill/QueueNado/git/refs{/sha}","trees_url":"https://api.github.com/repos/craig-cogdill/QueueNado/git/trees{/sha}","statuses_url":"https://api.github.com/repos/craig-cogdill/QueueNado/statuses/{sha}","languages_url":"https://api.github.com/repos/craig-cogdill/QueueNado/languages","stargazers_url":"https://api.github.com/repos/craig-cogdill/QueueNado/stargazers","contributors_url":"https://api.github.com/repos/craig-cogdill/QueueNado/contributors","subscribers_url":"https://api.github.com/repos/craig-cogdill/QueueNado/subscribers","subscription_url":"https://api.github.com/repos/craig-cogdill/QueueNado/subscription","commits_url":"https://api.github.com/repos/craig-cogdill/QueueNado/commits{/sha}","git_commits_url":"https://api.github.com/repos/craig-cogdill/QueueNado/git/commits{/sha}","comments_url":"https://api.github.com/repos/craig-cogdill/QueueNado/comments{/number}","issue_comment_url":"https://api.github.com/repos/craig-cogdill/QueueNado/issues/comments{/number}","contents_url":"https://api.github.com/repos/craig-cogdill/QueueNado/contents/{+path}","compare_url":"https://api.github.com/repos/craig-cogdill/QueueNado/compare/{base}...{head}","merges_url":"https://api.github.com/repos/craig-cogdill/QueueNado/merges","archive_url":"https://api.github.com/repos/craig-cogdill/QueueNado/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/craig-cogdill/QueueNado/downloads","issues_url":"https://api.github.com/repos/craig-cogdill/QueueNado/issues{/number}","pulls_url":"https://api.github.com/repos/craig-cogdill/QueueNado/pulls{/number}","milestones_url":"https://api.github.com/repos/craig-cogdill/QueueNado/milestones{/number}","notifications_url":"https://api.github.com/repos/craig-cogdill/QueueNado/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/craig-cogdill/QueueNado/labels{/name}","releases_url":"https://api.github.com/repos/craig-cogdill/QueueNado/releases{/id}","created_at":"2015-02-03T21:21:03Z","updated_at":"2015-02-03T21:21:05Z","pushed_at":"2015-08-28T19:31:57Z","git_url":"git://github.com/craig-cogdill/QueueNado.git","ssh_url":"git@github.com:craig-cogdill/QueueNado.git","clone_url":"https://github.com/craig-cogdill/QueueNado.git","svn_url":"https://github.com/craig-cogdill/QueueNado","homepage":null,"size":3276,"stargazers_count":0,"watchers_count":0,"language":"C++","has_issues":false,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":0,"mirror_url":null,"open_issues_count":0,"forks":0,"open_issues":0,"watchers":0,"default_branch":"master"}},"base":{"label":"weberr13:master","ref":"master","sha":"a10cd6a8114ae7d04a140906e3bd85c3f18e5736","user":{"login":"weberr13","id":4371459,"avatar_url":"https://avatars.githubusercontent.com/u/4371459?v=3","gravatar_id":"","url":"https://api.github.com/users/weberr13","html_url":"https://github.com/weberr13","followers_url":"https://api.github.com/users/weberr13/followers","following_url":"https://api.github.com/users/weberr13/following{/other_user}","gists_url":"https://api.github.com/users/weberr13/gists{/gist_id}","starred_url":"https://api.github.com/users/weberr13/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/weberr13/subscriptions","organizations_url":"https://api.github.com/users/weberr13/orgs","repos_url":"https://api.github.com/users/weberr13/repos","events_url":"https://api.github.com/users/weberr13/events{/privacy}","received_events_url":"https://api.github.com/users/weberr13/received_events","type":"User","site_admin":false},"repo":{"id":19793324,"name":"QueueNado","full_name":"weberr13/QueueNado","owner":{"login":"weberr13","id":4371459,"avatar_url":"https://avatars.githubusercontent.com/u/4371459?v=3","gravatar_id":"","url":"https://api.github.com/users/weberr13","html_url":"https://github.com/weberr13","followers_url":"https://api.github.com/users/weberr13/followers","following_url":"https://api.github.com/users/weberr13/following{/other_user}","gists_url":"https://api.github.com/users/weberr13/gists{/gist_id}","starred_url":"https://api.github.com/users/weberr13/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/weberr13/subscriptions","organizations_url":"https://api.github.com/users/weberr13/orgs","repos_url":"https://api.github.com/users/weberr13/repos","events_url":"https://api.github.com/users/weberr13/events{/privacy}","received_events_url":"https://api.github.com/users/weberr13/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/weberr13/QueueNado","description":"Implementation of fast queue patterns (Push/Pull, request/reply, pub/sub, dealer/router) for C++","fork":false,"url":"https://api.github.com/repos/weberr13/QueueNado","forks_url":"https://api.github.com/repos/weberr13/QueueNado/forks","keys_url":"https://api.github.com/repos/weberr13/QueueNado/keys{/key_id}","collaborators_url":"https://api.github.com/repos/weberr13/QueueNado/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/weberr13/QueueNado/teams","hooks_url":"https://api.github.com/repos/weberr13/QueueNado/hooks","issue_events_url":"https://api.github.com/repos/weberr13/QueueNado/issues/events{/number}","events_url":"https://api.github.com/repos/weberr13/QueueNado/events","assignees_url":"https://api.github.com/repos/weberr13/QueueNado/assignees{/user}","branches_url":"https://api.github.com/repos/weberr13/QueueNado/branches{/branch}","tags_url":"https://api.github.com/repos/weberr13/QueueNado/tags","blobs_url":"https://api.github.com/repos/weberr13/QueueNado/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/weberr13/QueueNado/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/weberr13/QueueNado/git/refs{/sha}","trees_url":"https://api.github.com/repos/weberr13/QueueNado/git/trees{/sha}","statuses_url":"https://api.github.com/repos/weberr13/QueueNado/statuses/{sha}","languages_url":"https://api.github.com/repos/weberr13/QueueNado/languages","stargazers_url":"https://api.github.com/repos/weberr13/QueueNado/stargazers","contributors_url":"https://api.github.com/repos/weberr13/QueueNado/contributors","subscribers_url":"https://api.github.com/repos/weberr13/QueueNado/subscribers","subscription_url":"https://api.github.com/repos/weberr13/QueueNado/subscription","commits_url":"https://api.github.com/repos/weberr13/QueueNado/commits{/sha}","git_commits_url":"https://api.github.com/repos/weberr13/QueueNado/git/commits{/sha}","comments_url":"https://api.github.com/repos/weberr13/QueueNado/comments{/number}","issue_comment_url":"https://api.github.com/repos/weberr13/QueueNado/issues/comments{/number}","contents_url":"https://api.github.com/repos/weberr13/QueueNado/contents/{+path}","compare_url":"https://api.github.com/repos/weberr13/QueueNado/compare/{base}...{head}","merges_url":"https://api.github.com/repos/weberr13/QueueNado/merges","archive_url":"https://api.github.com/repos/weberr13/QueueNado/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/weberr13/QueueNado/downloads","issues_url":"https://api.github.com/repos/weberr13/QueueNado/issues{/number}","pulls_url":"https://api.github.com/repos/weberr13/QueueNado/pulls{/number}","milestones_url":"https://api.github.com/repos/weberr13/QueueNado/milestones{/number}","notifications_url":"https://api.github.com/repos/weberr13/QueueNado/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/weberr13/QueueNado/labels{/name}","releases_url":"https://api.github.com/repos/weberr13/QueueNado/releases{/id}","created_at":"2014-05-14T19:34:03Z","updated_at":"2015-06-21T12:07:16Z","pushed_at":"2015-08-28T19:36:39Z","git_url":"git://github.com/weberr13/QueueNado.git","ssh_url":"git@github.com:weberr13/QueueNado.git","clone_url":"https://github.com/weberr13/QueueNado.git","svn_url":"https://github.com/weberr13/QueueNado","homepage":null,"size":3394,"stargazers_count":6,"watchers_count":6,"language":"C++","has_issues":true,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":5,"mirror_url":null,"open_issues_count":2,"forks":5,"open_issues":2,"watchers":6,"default_branch":"master"}},"_links":{"self":{"href":"https://api.github.com/repos/weberr13/QueueNado/pulls/19"},"html":{"href":"https://github.com/weberr13/QueueNado/pull/19"},"issue":{"href":"https://api.github.com/repos/weberr13/QueueNado/issues/19"},"comments":{"href":"https://api.github.com/repos/weberr13/QueueNado/issues/19/comments"},"review_comments":{"href":"https://api.github.com/repos/weberr13/QueueNado/pulls/19/comments"},"review_comment":{"href":"https://api.github.com/repos/weberr13/QueueNado/pulls/comments{/number}"},"commits":{"href":"https://api.github.com/repos/weberr13/QueueNado/pulls/19/commits"},"statuses":{"href":"https://api.github.com/repos/weberr13/QueueNado/statuses/e909ab5764b6ba41379abea5dac0a579b41c425f"}}}}