Silent failures with an existing queue

[unthingable]

val opRabbitVersion = "1.1.2"

Scenario:

  val subscriptionRef = Subscription.run(rabbitControl) {
    channel(qos = 1) {
      consume(
        topic("foo", List("#"), exchange = "some_exchange")
      ) {....

If the queue does not exist, op-rabbit creates it, all is well. Creating the queue manually (via the management plugin) works too.

However, creating the same queue manually with x-max-length:10000 and then starting the Subscription results in messages not being consumed. No errors reported.

[unthingable]

Nevermind, just found def passive[T <: Concreteness](binding: QueueDefinition[T]): which looks like exactly what I need.

The ask is therefore reduced to having this mentioned in the documentation. :)

[timcharper]

Resolved by 9984d72. Thanks for the report, and sorry about this! What a terrible issue to encounter.

[timcharper]

Release v1.1.3 includes the fix.

[timcharper]

#46