{"action":"created","issue":{"url":"https://api.github.com/repos/dnvriend/reactive-activemq/issues/5","repository_url":"https://api.github.com/repos/dnvriend/reactive-activemq","labels_url":"https://api.github.com/repos/dnvriend/reactive-activemq/issues/5/labels{/name}","comments_url":"https://api.github.com/repos/dnvriend/reactive-activemq/issues/5/comments","events_url":"https://api.github.com/repos/dnvriend/reactive-activemq/issues/5/events","html_url":"https://github.com/dnvriend/reactive-activemq/pull/5","id":172791541,"number":5,"title":"Parallellism","user":{"login":"mboogerd","id":4114816,"avatar_url":"https://avatars.githubusercontent.com/u/4114816?v=3","gravatar_id":"","url":"https://api.github.com/users/mboogerd","html_url":"https://github.com/mboogerd","followers_url":"https://api.github.com/users/mboogerd/followers","following_url":"https://api.github.com/users/mboogerd/following{/other_user}","gists_url":"https://api.github.com/users/mboogerd/gists{/gist_id}","starred_url":"https://api.github.com/users/mboogerd/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mboogerd/subscriptions","organizations_url":"https://api.github.com/users/mboogerd/orgs","repos_url":"https://api.github.com/users/mboogerd/repos","events_url":"https://api.github.com/users/mboogerd/events{/privacy}","received_events_url":"https://api.github.com/users/mboogerd/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-08-23T19:56:57Z","updated_at":"2016-08-23T20:22:09Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/dnvriend/reactive-activemq/pulls/5","html_url":"https://github.com/dnvriend/reactive-activemq/pull/5","diff_url":"https://github.com/dnvriend/reactive-activemq/pull/5.diff","patch_url":"https://github.com/dnvriend/reactive-activemq/pull/5.patch"},"body":"Two significant changes:\r\n- ActiveMqConsumer now includes a poolSize, which controls the maximum number of parallel in-transit requests. It uses the simplest mechanism I could find (although more costly than I had hoped for), simply instantiating multiple ActiveMq-sources and combining them into one. **Use case**: I like to use 'grouped' combinator to create mini-batches over a window. This mechanism could not be put to effective use with a Source that allows only a single in-transit message\r\n- Included Recorrelator, which allows for a cleaner application interface (not thinking in 'technical' terms of promises/actor-refs). The supplied correlator defines a context for the message that is used to find back the original promise-actor-ref. **Use case**: The AckBidiFlow does not deal with the application-flow being disorderly. Recorrelator is not sensitve to reordering (but admittedly, still has a bunch of possible improvements.)\r\n\r\nLet me know what you think! :)\r\n"},"comment":{"url":"https://api.github.com/repos/dnvriend/reactive-activemq/issues/comments/241864689","html_url":"https://github.com/dnvriend/reactive-activemq/pull/5#issuecomment-241864689","issue_url":"https://api.github.com/repos/dnvriend/reactive-activemq/issues/5","id":241864689,"user":{"login":"codacy-bot","id":19940114,"avatar_url":"https://avatars.githubusercontent.com/u/19940114?v=3","gravatar_id":"","url":"https://api.github.com/users/codacy-bot","html_url":"https://github.com/codacy-bot","followers_url":"https://api.github.com/users/codacy-bot/followers","following_url":"https://api.github.com/users/codacy-bot/following{/other_user}","gists_url":"https://api.github.com/users/codacy-bot/gists{/gist_id}","starred_url":"https://api.github.com/users/codacy-bot/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/codacy-bot/subscriptions","organizations_url":"https://api.github.com/users/codacy-bot/orgs","repos_url":"https://api.github.com/users/codacy-bot/repos","events_url":"https://api.github.com/users/codacy-bot/events{/privacy}","received_events_url":"https://api.github.com/users/codacy-bot/received_events","type":"User","site_admin":false},"created_at":"2016-08-23T20:22:09Z","updated_at":"2016-08-23T20:22:09Z","body":"\n![Codacy](https://www.codacy.com/assets/images/favicon.png) Here is an overview of what got changed by this pull request:\n\n\n```diff\n\nIssues\n======\n- Added 1\n           \n\nComplexity increasing per file\n==============================\n- src/main/scala/akka/stream/integration/activemq/RecorrelatorBidiFlow.scala  9\n         \n\nClones added\n============\n- src/main/scala/akka/stream/integration/activemq/ActiveMqReqRespFlow.scala  1\n- src/main/scala/akka/stream/integration/activemq/ActiveMqFlow.scala  3\n         \n```\n\n\nSee the complete overview on [Codacy](https://www.codacy.com/app/dnvriend/reactive-activemq/pullRequest?prid=326271&bid=3624342)\n        "}}
{"actor":{"display_login":"codacy-bot"}}