diff options
| author | Jean-Sébastien Pédron <jean-sebastien.pedron@dumbbell.fr> | 2023-03-08 13:14:15 +0100 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien.pedron@dumbbell.fr> | 2023-03-10 09:25:38 +0100 |
| commit | 7a42c485f6ff0bd1fe0e754a8f1439a70190cb6b (patch) | |
| tree | 5675f9ca28d1791f50399d661cee0769cc44e1a5 | |
| parent | 9d72450f93034117eb6470fa4dd1265bfa0ba7f8 (diff) | |
| download | rabbitmq-server-git-7a42c485f6ff0bd1fe0e754a8f1439a70190cb6b.tar.gz | |
amqqueue: Fix spec of `#amqqueue{}`
`policy` and `operator_policy` store the policy properties, not the
policy name. Therefore, it is a proplist, not a binary.
| -rw-r--r-- | deps/rabbit/src/amqqueue.erl | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/deps/rabbit/src/amqqueue.erl b/deps/rabbit/src/amqqueue.erl index 081b32dda2..e5bb5f4ff1 100644 --- a/deps/rabbit/src/amqqueue.erl +++ b/deps/rabbit/src/amqqueue.erl @@ -98,16 +98,16 @@ slave_pids = [] :: [pid()] | none | '_', %% transient sync_slave_pids = [] :: [pid()] | none| '_',%% transient recoverable_slaves = [] :: [atom()] | none | '_', %% durable - policy :: binary() | none | undefined | '_', %% durable, implicit - %% update as above - operator_policy :: binary() | none | undefined | '_', %% durable, - %% implicit - %% update - %% as above + policy :: proplists:proplist() | + none | undefined | '_', %% durable, implicit update as + %% above + operator_policy :: proplists:proplist() | + none | undefined | '_', %% durable, implicit + %% update as above gm_pids = [] :: [{pid(), pid()}] | none | '_', %% transient decorators :: [atom()] | none | undefined | '_', %% transient, - %% recalculated - %% as above + %% recalculated + %% as above state = live :: atom() | none | '_', %% durable (have we crashed?) policy_version = 0 :: non_neg_integer() | '_', slave_pids_pending_shutdown = [] :: [pid()] | '_', @@ -128,8 +128,9 @@ slave_pids :: [pid()] | none, sync_slave_pids :: [pid()] | none, recoverable_slaves :: [atom()] | none, - policy :: binary() | none | undefined, - operator_policy :: binary() | none | undefined, + policy :: proplists:proplist() | none | undefined, + operator_policy :: proplists:proplist() | + none | undefined, gm_pids :: [{pid(), pid()}] | none, decorators :: [atom()] | none | undefined, state :: atom() | none, |