diff options
| author | Michael Klishin <klishinm@vmware.com> | 2021-05-12 09:11:18 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-05-12 09:11:18 +0300 |
| commit | 70adc2ea5dadf9e1667fcca87cd20bb3d06e8780 (patch) | |
| tree | 304e580e757e2384e5773c125fa46cd93ddfb9cf | |
| parent | 9c103df2ce98aa3eb1f5e13ad48c00978db553ba (diff) | |
| parent | 13a31a49f3ce68d450e171a8b6d95e6c0704ee32 (diff) | |
| download | rabbitmq-server-git-70adc2ea5dadf9e1667fcca87cd20bb3d06e8780.tar.gz | |
Merge pull request #3036 from rabbitmq/mk-amqqueue-set-options
Introduce amqqueue:set_options/2
| -rw-r--r-- | deps/rabbit/src/amqqueue.erl | 9 | ||||
| -rw-r--r-- | deps/rabbit/src/amqqueue_v1.erl | 9 |
2 files changed, 18 insertions, 0 deletions
diff --git a/deps/rabbit/src/amqqueue.erl b/deps/rabbit/src/amqqueue.erl index faa98efd45..31cc650879 100644 --- a/deps/rabbit/src/amqqueue.erl +++ b/deps/rabbit/src/amqqueue.erl @@ -38,7 +38,9 @@ % operator_policy get_operator_policy/1, set_operator_policy/2, + % options get_options/1, + set_options/2, % pid get_pid/1, set_pid/2, @@ -482,6 +484,13 @@ set_name(Queue, Name) -> get_options(#amqqueue{options = Options}) -> Options; get_options(Queue) -> amqqueue_v1:get_options(Queue). +-spec set_options(amqqueue(), map()) -> amqqueue(). + +set_options(#amqqueue{} = Queue, Options) -> + Queue#amqqueue{options = Options}; +set_options(Queue, Options) -> + amqqueue_v1:set_options(Queue, Options). + % pid -spec get_pid diff --git a/deps/rabbit/src/amqqueue_v1.erl b/deps/rabbit/src/amqqueue_v1.erl index c672d732b2..2821b07b56 100644 --- a/deps/rabbit/src/amqqueue_v1.erl +++ b/deps/rabbit/src/amqqueue_v1.erl @@ -38,7 +38,9 @@ % operator_policy get_operator_policy/1, set_operator_policy/2, + % options get_options/1, + set_options/2, % pid get_pid/1, set_pid/2, @@ -392,10 +394,17 @@ get_name(#amqqueue{name = Name}) -> Name. set_name(#amqqueue{} = Queue, Name) -> Queue#amqqueue{name = Name}. +%% options + -spec get_options(amqqueue()) -> map(). get_options(#amqqueue{options = Options}) -> Options. +-spec set_options(amqqueue(), map()) -> amqqueue(). + +set_options(#amqqueue{} = Queue, Options) -> + Queue#amqqueue{options = Options}. + % pid -spec get_pid |