{"action":"created","issue":{"url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/issues/287","repository_url":"https://api.github.com/repos/IBMStreams/streamsx.messaging","labels_url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/issues/287/labels{/name}","comments_url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/issues/287/comments","events_url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/issues/287/events","html_url":"https://github.com/IBMStreams/streamsx.messaging/pull/287","id":190247571,"number":287,"title":"[WIP] Ensuring at least once with consistent region","user":{"login":"ddebrunner","id":3769612,"avatar_url":"https://avatars.githubusercontent.com/u/3769612?v=3","gravatar_id":"","url":"https://api.github.com/users/ddebrunner","html_url":"https://github.com/ddebrunner","followers_url":"https://api.github.com/users/ddebrunner/followers","following_url":"https://api.github.com/users/ddebrunner/following{/other_user}","gists_url":"https://api.github.com/users/ddebrunner/gists{/gist_id}","starred_url":"https://api.github.com/users/ddebrunner/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ddebrunner/subscriptions","organizations_url":"https://api.github.com/users/ddebrunner/orgs","repos_url":"https://api.github.com/users/ddebrunner/repos","events_url":"https://api.github.com/users/ddebrunner/events{/privacy}","received_events_url":"https://api.github.com/users/ddebrunner/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-11-18T06:42:09Z","updated_at":"2016-11-18T14:01:20Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/pulls/287","html_url":"https://github.com/IBMStreams/streamsx.messaging/pull/287","diff_url":"https://github.com/IBMStreams/streamsx.messaging/pull/287.diff","patch_url":"https://github.com/IBMStreams/streamsx.messaging/pull/287.patch"},"body":"* Maintain futures of sent messages\r\n* Implement drain to wait for all messages to be sent to the broker\r\n* Also call drain on a final marker to ensure messages are flushed before any shutdown.\r\n* Ensure any exception during processing will cause a drain to fail\r\n\r\nStill to be done:\r\n* Correct exception handling in a consistent region"},"comment":{"url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/issues/comments/261538164","html_url":"https://github.com/IBMStreams/streamsx.messaging/pull/287#issuecomment-261538164","issue_url":"https://api.github.com/repos/IBMStreams/streamsx.messaging/issues/287","id":261538164,"user":{"login":"petenicholls","id":5529592,"avatar_url":"https://avatars.githubusercontent.com/u/5529592?v=3","gravatar_id":"","url":"https://api.github.com/users/petenicholls","html_url":"https://github.com/petenicholls","followers_url":"https://api.github.com/users/petenicholls/followers","following_url":"https://api.github.com/users/petenicholls/following{/other_user}","gists_url":"https://api.github.com/users/petenicholls/gists{/gist_id}","starred_url":"https://api.github.com/users/petenicholls/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/petenicholls/subscriptions","organizations_url":"https://api.github.com/users/petenicholls/orgs","repos_url":"https://api.github.com/users/petenicholls/repos","events_url":"https://api.github.com/users/petenicholls/events{/privacy}","received_events_url":"https://api.github.com/users/petenicholls/received_events","type":"User","site_admin":false},"created_at":"2016-11-18T14:01:20Z","updated_at":"2016-11-18T14:01:20Z","body":"Do we really need to maintain the future list?  If we call flush() in the drain method will that block until all messages are delivered and any problems will result in the callback being invoked from the original send call?"}}
{"actor":{"display_login":"petenicholls"}}