{"push_id":3045792418,"size":13,"distinct_size":1,"ref":"refs/heads/sqs-ack","head":"867ddf5f6f285186947228dcdc719e5d8f4e290a","before":"7fcee15c91c3348713710abbe37ea59a5283db77","commits":[{"sha":"41a2e5c4c0ca83e80be1519e71694f9577ade68a","author":{"name":"Martynas Mickevičius","email":"40380bc1d358a6f8665b37bbdc8c7ccc6c38a861@2m.lt"},"message":"Fetch full history in Travis so version can always be determined","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/41a2e5c4c0ca83e80be1519e71694f9577ade68a"},{"sha":"aee9ebeb422eeb8623d4b59f8d8c96e30f21241d","author":{"name":"Martynas Mickevičius","email":"40380bc1d358a6f8665b37bbdc8c7ccc6c38a861@2m.lt"},"message":"Merge pull request #1305 from 2m/wip-full-history-2m\n\nFetch full history in Travis so version can always be determined","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/aee9ebeb422eeb8623d4b59f8d8c96e30f21241d"},{"sha":"fe367429ffd02160ea5c043ee0fec93f46dd8a6e","author":{"name":"Martynas Mickevičius","email":"40380bc1d358a6f8665b37bbdc8c7ccc6c38a861@2m.lt"},"message":"Update to the latest Akka Paradox that adds icons to goto source links (#1309)","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/fe367429ffd02160ea5c043ee0fec93f46dd8a6e"},{"sha":"eb927fa2003625cbf728f42d2fd50f7b6d6efc12","author":{"name":"Danny Lesnik","email":"c7ebc35d0fd5db5bbd5a4aef4bce4b1c7acc5c06@users.noreply.github.com"},"message":"Couchbase connector (#1203)\n\n- Scala DSL (Source, Sink & Flow)\r\n- Java DSL (Source, Sink & Flow)\r\n- Docker compose with latest Community Edition Couchbase server image\r\n- unit tests running on single node CB cluster created on the fly\r\n- Paradox documentation for Java and Scala DSL","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/eb927fa2003625cbf728f42d2fd50f7b6d6efc12"},{"sha":"4dc4c213bf0baa230bffbbfd6178d62646f3356d","author":{"name":"Christopher Hunt","email":"8921e58aed1d400f6e275145ea9f3f7dec96f60b@gmail.com"},"message":"MQTT streaming: Handle connect while connected (#1312)\n\nA situation can occur where a CONNECT is received by the MQTT server while in a state of already being connected. In this case, we need to process the new CONNECT i.e. CONNACK it etc.","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/4dc4c213bf0baa230bffbbfd6178d62646f3356d"},{"sha":"daba7df05114420c7470962310e0ed8d0557150c","author":{"name":"Michael Pisula","email":"bcd8e35236438e5f0c9e1fa4afe1784b68af823e@googlemail.com"},"message":"Add retries for S3 internal errors (#1303)\n\n* Add retries for S3 internal errors","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/daba7df05114420c7470962310e0ed8d0557150c"},{"sha":"95dd10408d0b276e943282d9324e561ee85f7e4c","author":{"name":"Danny Lesnik","email":"c7ebc35d0fd5db5bbd5a4aef4bce4b1c7acc5c06@users.noreply.github.com"},"message":"Avro Parquet -  AvroParquetSinkTest.createNewParquetFile #1316 (#1319)\n\nFile size was zero because ParquetWriter was not closed. \r\n\r\nIt happened due to one of two options:\r\n-  Either  `Source.from(records).runWith(sink, materializer)` took more then 1 sec.\r\n-  There was an uncaught exception in Sink.","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/95dd10408d0b276e943282d9324e561ee85f7e4c"},{"sha":"e977c4898665901c37f8a97ca730f2c9cb6e6468","author":{"name":"sergeantwolf","email":"c123c1e9225659809d31576230b2b20da1f96f2a@yandex.ru"},"message":"Elasticsearch: failStage should happen when shouldRetry returns false (#1302)\n\nFixes #1300","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/e977c4898665901c37f8a97ca730f2c9cb6e6468"},{"sha":"dfb28667b168159379b60b95630591358ba6fb4e","author":{"name":"Grigorii Chudnov","email":"6aad914c0e73d32a91d1b72a1d969b0ad14c1884@gmail.com"},"message":"AWS S3: make path-style access default (#1152) (#1308)","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/dfb28667b168159379b60b95630591358ba6fb4e"},{"sha":"595f9decbde92fcc933f3268ef102b182159e012","author":{"name":"Christopher Hunt","email":"8921e58aed1d400f6e275145ea9f3f7dec96f60b@gmail.com"},"message":"MQTT streaming: Resilient client publications (#1315)\n\nClient publications wouldn’t previously withstand a connection being lost, whereas server publications would. I’ve now aligned the client publication handling with the server publication handling.\r\n\r\nIn addition, session objects are now told to perform a publish command directly. The rationale is that the session object is the only thing that can guarantee the QoS requirements of a PUBLISH. I use the \"tell\" syntax of actors as I feel that it has the same meaning i.e. \"communicate directly\". For example:\r\n\r\n```scala\r\nclientSession ! Command(Publish(topic, ByteString(\"ohi\")))\r\n```\r\n\r\nPrior to this work, PUBLISH commands were communicated with a command flow, which is often associated with a network connection. The problem with the approach was that PUBLISH commands could be lost if a network connection was lost i.e. the command is consumed, sent via TCP, TCP fails, and the command is lost. To substantiate this, TCP flows were often coupled with `RestartFlow`, which states, _\"The restart process is inherently lossy, ...\"_.\r\n\r\nI've tested these changes with an external program and observed that publications recover from a loss of network connectivity.","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/595f9decbde92fcc933f3268ef102b182159e012"},{"sha":"d48fcc16613af778ff3a407bc04b817db933842d","author":{"name":"Ewan Keith","email":"5d7b33287d2a6505514b3feb5d1e594d355cec8b@yahoo.co.uk"},"message":"Fixed 2 dead links in the contributing guidelines (#1325)\n\nThe links to O'Reilly were redirecting to their home page. Pointed them at what I'm assuming is the new home for each resource.","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/d48fcc16613af778ff3a407bc04b817db933842d"},{"sha":"de0ab9aa7df68e7464650bac2dfe01018fd40772","author":{"name":"Michel Davit","email":"3ccfab76d31b4a04ee0bbec1278921d20c82ba1e@gmail.com"},"message":"AWS SQS: Add equals/hashCode to SQS model classes (#1311)","distinct":false,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/de0ab9aa7df68e7464650bac2dfe01018fd40772"},{"sha":"867ddf5f6f285186947228dcdc719e5d8f4e290a","author":{"name":"Michel Davit","email":"d76678e36868ac40bae1d07e0d1cfdc53eef11dd@ryte.com"},"message":"WIP","distinct":true,"url":"https://api.github.com/repos/RustedBones/alpakka/commits/867ddf5f6f285186947228dcdc719e5d8f4e290a"}]}
{"actor":{"display_login":"RustedBones"}}