{"action":"created","issue":{"url":"https://api.github.com/repos/rchain/rchain/issues/1514","repository_url":"https://api.github.com/repos/rchain/rchain","labels_url":"https://api.github.com/repos/rchain/rchain/issues/1514/labels{/name}","comments_url":"https://api.github.com/repos/rchain/rchain/issues/1514/comments","events_url":"https://api.github.com/repos/rchain/rchain/issues/1514/events","html_url":"https://github.com/rchain/rchain/pull/1514","id":362338034,"node_id":"MDExOlB1bGxSZXF1ZXN0MjE3MDg1NTUy","number":1514,"title":"Implement message queues in TCP transport layer","user":{"login":"sebtomba","id":6872800,"node_id":"MDQ6VXNlcjY4NzI4MDA=","avatar_url":"https://avatars3.githubusercontent.com/u/6872800?v=4","gravatar_id":"","url":"https://api.github.com/users/sebtomba","html_url":"https://github.com/sebtomba","followers_url":"https://api.github.com/users/sebtomba/followers","following_url":"https://api.github.com/users/sebtomba/following{/other_user}","gists_url":"https://api.github.com/users/sebtomba/gists{/gist_id}","starred_url":"https://api.github.com/users/sebtomba/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sebtomba/subscriptions","organizations_url":"https://api.github.com/users/sebtomba/orgs","repos_url":"https://api.github.com/users/sebtomba/repos","events_url":"https://api.github.com/users/sebtomba/events{/privacy}","received_events_url":"https://api.github.com/users/sebtomba/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-09-20T19:44:32Z","updated_at":"2018-09-20T19:47:36Z","closed_at":null,"author_association":"COLLABORATOR","pull_request":{"url":"https://api.github.com/repos/rchain/rchain/pulls/1514","html_url":"https://github.com/rchain/rchain/pull/1514","diff_url":"https://github.com/rchain/rchain/pull/1514.diff","patch_url":"https://github.com/rchain/rchain/pull/1514.patch"},"body":"## Overview\r\nImplement message queues in TCP transport layer with Monix `Observable` and parallel dispatching of messages. The messaging pattern is motivated by actor systems. There is a `tell` operation for one-way messages without a reply. However, the client waits for the message being delivered and enqueued to a message queue on the peer node. The second operation is `ask` for request-response messaging. This operation is also served over a message queue with a callback. The `tell` and `ask` messages queues are getting zipped into one message queue and then dispatched in parallel. The default parallelism is the number of CPU cores.\r\n \r\n### Which JIRA issue does this PR relate to? If there is not a JIRA issue addressing this work, please create one now and add the link here.\r\nhttps://rchain.atlassian.net/browse/CORE-1148\r\n\r\n### Complete this checklist before you submit the PR\r\n- [ ] This PR contains no more than 200 lines of code, excluding test code.\r\n- [x] This PR meets [RChain development coding standards](https://rchain.atlassian.net/wiki/spaces/DOC/pages/28082177/Coding+Standards).\r\n- [x] You assigned one person to review this PR\r\n"},"comment":{"url":"https://api.github.com/repos/rchain/rchain/issues/comments/423309781","html_url":"https://github.com/rchain/rchain/pull/1514#issuecomment-423309781","issue_url":"https://api.github.com/repos/rchain/rchain/issues/1514","id":423309781,"node_id":"MDEyOklzc3VlQ29tbWVudDQyMzMwOTc4MQ==","user":{"login":"goral09","id":5120801,"node_id":"MDQ6VXNlcjUxMjA4MDE=","avatar_url":"https://avatars2.githubusercontent.com/u/5120801?v=4","gravatar_id":"","url":"https://api.github.com/users/goral09","html_url":"https://github.com/goral09","followers_url":"https://api.github.com/users/goral09/followers","following_url":"https://api.github.com/users/goral09/following{/other_user}","gists_url":"https://api.github.com/users/goral09/gists{/gist_id}","starred_url":"https://api.github.com/users/goral09/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/goral09/subscriptions","organizations_url":"https://api.github.com/users/goral09/orgs","repos_url":"https://api.github.com/users/goral09/repos","events_url":"https://api.github.com/users/goral09/events{/privacy}","received_events_url":"https://api.github.com/users/goral09/received_events","type":"User","site_admin":false},"created_at":"2018-09-20T19:47:36Z","updated_at":"2018-09-20T19:47:36Z","author_association":"COLLABORATOR","body":"Will review tomorrow, but I have a question already, @sebtomba did you make a performance tests? Because from the description it sounds like awful lot of awaiting/synchronization. Is this gonna happen for every message sent to any node?"}}
{"actor":{"display_login":"goral09"}}