| Commit message (Collapse) | Author | Age | Files | Lines |
|---|
| | |
|
| |
|
|
| |
When there are consumers in the service queue.
|
| |
|
|
|
|
|
|
| |
Detect when a new stream leader is elected and make stream_queues
re-send any unconfirmed, pending messages to ensure they did not get
lost during the leader change. This is done using the osiris
deduplication feature to ensure the resend does not create duplicates of
messages in the stream.
|
| | |
|
| |
|
|
| |
In any other case, the worker needs to be restarted
|
| |
|
|
|
|
| |
Bypassing PEM cache may speed up TLS handshakes in some cases as described
here:
https://blog.heroku.com/how-we-sped-up-sni-tls-handshakes-by-5x
|
| | |
|
| |
|
|
|
|
| |
as opposed to a comma-separated binary.
Part of #2667.
|
| |
|
|
|
|
|
|
|
|
| |
As the connection may crash during the previous declaration and a caught
error would be returned in amqp_connection:open_channel/1 that wasn't
handled previously. Exactly how things fail in this test is most likely
very timing dependent and may vary.
Also fixes mqtt test where the process that set up a mock auth ETS table
was transient when an rpc timeout was introduced
|
| | |
|
| |\
| |
| | |
Support timestamp offsets for stream consumers
|
| | |
| |
| |
| | |
For start offset in stream queue.
|
| | | |
|
| |/
|
|
|
|
| |
Else an application that polled an empty quorum queue frequntly using basic.get
would never result in a snapshot being taken and results in unlimited
log growth.
|
| |
|
|
|
| |
When the x-credit consumer arg is defined Quorum Queues should use use
credit mode `credited` and not `simple_prefetch`.
|
|
|
rabbit must not be the monorepo root application, as other applications depend on it
|
