wabbit
wabbit copied to clipboard
GenStage based interface for RabbitMQ
Addresses #13 . Limitation observed, it does not mix well with use of `amqp://...` style URIs.
Hopefully @pma or @peterkrenn will re-engage soon. In the meantime, some interesting fixes live in https://github.com/martin-langhoff/wabbit
There is a bug in this function: https://github.com/pma/wabbit/blob/master/lib/wabbit/gen_stage.ex#L271 There is not "module" key in state: https://github.com/pma/wabbit/blob/master/lib/wabbit/gen_stage.ex#L6 Fix could look like this: ``` defp noreply_callback(callback, args, %__MODULE__{mod: module} = state) do...
I'd be nice to have support for ``` config :wabbit, host: "localhost" port: 5672, username: "someapp", password: "changeme" ``` which in turn can be driven by conform or similar for...
Is it possible to consume from a queue without ACK'ing? I used to do this in `amqp` without problems but in `wabbit` I haven't been able to do so. Can...
I'm aware that this library is likely EOL (#18) but wanted to share this in case others are seeing the same issue. --- The `dispatch_events` function contains a bug when...