Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

Hi, Thanks for the fixes, the ack issue especially was pretty much a showstopper. The acknowledged streams seem very nice. I haven't gotten into the small details, but at a high level they do seem to be what I was looking for. It would be nice if, as you mentioned in the blog, you extracted the

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

I responded to your issues by commenting on your github fork; all those issues have been resolved, and there are tests in place to assert the functionality is retained. Also, I've pushed in a new concept of acknowledged streams with the recent v1.0.0-M9 release. The reasoning behind the change c

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

Hi Tim, Sorry to disappear on you like that, priorities got shifted a little here and I had to work on something else for a while. I'm back to working on this now, though, and it seems like there have been a lot of changes in the meantime! So I created a new project, started with the sample co

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

> On May 28, 2015, at 06:25, Tal Pressman wrote: > > > > On Thursday, May 28, 2015 at 1:26:28 AM UTC+3, Tim Harper wrote: > > You're right; after the retry amount, the messages are lost. Also, worse, is > that message order is not maintained. This makes the recovery strategy good > only whe

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

On Thursday, May 28, 2015 at 1:26:28 AM UTC+3, Tim Harper wrote: You're right; after the retry amount, the messages are lost. Also, worse, > is that message order is not maintained. This makes the recovery strategy > good only when message order does not matter. I had to do this because I > u

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

> On May 27, 2015, at 07:47, Tal Pressman wrote: > > Hi Tim, > > This looks great - I was just thinking of implementing something like this > myself, so the timing couldn't have been better. ^_^ Glad to hear it! > I do have a couple of questions, though. > > From what I see in AsyncAckingC

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

This is actually a fairly interesting problem that I've been putting a lot of thought into lately as well. I've been working on a (very rough) ground-up implementation of AMQP using the new StreamTcp API, and I've run into an interesting problem with RabbitMQ. Basically, AMQP uses the concept o

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

> 14 maj 2015 kl. 00:43 skrev Tim Harper : > > >> On May 13, 2015, at 01:15, Roland Kuhn > > wrote: >> >> Hi Tim, >> >> this looks like a very nice package, thanks for sharing! Since I am not that >> deeply into RabbitMQ, I guess the “opinionated” part is about favor

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

> On May 13, 2015, at 01:15, Roland Kuhn wrote: > > Hi Tim, > > this looks like a very nice package, thanks for sharing! Since I am not that > deeply into RabbitMQ, I guess the “opinionated” part is about favoring > at-least-once guarantees and explicit acknowledgement over magic? This would

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

Hi Rob, > On May 13, 2015, at 09:48, Rob Moore wrote: > > Hi, Tim, > > Thanks for making this library available. I noticed the dependency on your > scoped-fixtures library. Is that something that you plan on open sourcing as > well? Certainly! https://github.com/SpinGo/scoped-fixtures

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

Hi Tim, this looks like a very nice package, thanks for sharing! Since I am not that deeply into RabbitMQ, I guess the “opinionated” part is about favoring at-least-once guarantees and explicit acknowledgement over magic? This would fit in well with the overall Akka philosophy, and that would p

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

Unfortunately, Joseph, I think the answer here is no; this library will not reduce dependencies on any of the services you specify. It helps Scala applications integrate with RabbitMQ. On Monday, May 11, 2015 at 8:53:57 PM UTC-6, Joseph Mansigian wrote: > > Hello Tim, > > I saw your post about t

Re: [akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

Hello Tim, I saw your post about the library you developed and wonder if it can help me with a problem. I have a Java/Akka project that is now run from the command line. Currently anyone who wants to see what it can do has to install/already have: - git - java - scala - akka - ya

[akka-user] Announcement: Opinionated RabbitMQ library using Akka / Reactive Streams

I have developed a high-level library for efficiently setting up resilient, fault-tolerant RabbitMQ consumers using Akka and Akka Reactive Streams. Some of the features: - Recovery: - Consumers automatically reconnect and subscribe if the connection is lost - Messages published can opt