Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/104
To handle the use case of a Rabbit cluster with non-HA queues where the node hosting
a queue is down, set `missingQueuesFatal` to `false` by default.
Expose this property in the consumer config, together with the redeclaration retry properties.
Docs
Fixesspring-cloud/spring-cloud-stream-binder-rabbit#95
* To avoid blocked connection dead lock on consumers add
`ConnectionFactory` clone in the `RabbitMessageChannelBinder` for
non-transactional producers
* Add `DisposableBean` implementation into the `RabbitMessageChannelBinder`
to `destroy` all the spawned internal connection factories including
`LocalizedQueueConnectionFactory`
Address some PR comments:
* Copy `RabbitConnectionFactory` from the injected `CCF`
* Don't wrap `producerCF` into the `LocalizedQueueCF`
* Polishing code style
Make Latebinding test transactional
So the same connection factory is used.
There is a race condition in the proxy.
Resolves#9
Replace with simply `headerPatterns`.
The reply header patterns were never used and are removed.
The request header patterns are deprecated in favor of header patterns.
Fixes#48
The commit for #34 inadvertently set the exchange to be non-durable (won't survive a
broker restart).
Revert to durable exchanges by default and add a configuration option.
Also add an option to auto-delete the exchange.
Fix clean up of custom dead letter exchange in tests.
Clean up some compiler warnings.
Revert Deprecated Import
Document New Properties
Also fix sort and name of `bindingRoutingKey` on the producer side.
Resolves#23Resolves#24
- support queue arguments - ttl,expires, max-length, max-length-bytes, max-priority
- also on DLQ (if auto-bound)
- also allow customization of dead letter exchange/routing key
- support DLX/DLQ configuration on the DLQ as well - combined with TTL can be used to route back to primary queue
Polishing and Document DLQ/TTL Retries Technique
Doc Polishing
Resolves#34Resolves#26
- Add properties to support user configuration of exchanges/queues
-- Disable binding and exchange declaration, giving complete control
-- Allow the exchange type to be specified and, for non-partitioned destinations, the routing key.
- Add support for the Delayed Message Exchange broker plugin
Doc Polishing
Polishing; add delay header; add outbound routingKey config
