summaryrefslogtreecommitdiff
path: root/src/mod_muc.erl
diff options
context:
space:
mode:
authorEvgeniy Khramtsov <ekhramtsov@process-one.net>2017-05-04 12:24:47 +0300
committerEvgeniy Khramtsov <ekhramtsov@process-one.net>2017-05-04 12:24:47 +0300
commitcf53d834e9931151a46fed31e644d7eb05e816be (patch)
tree0c559620641e6225adb3c2e5c3848b85a72250bc /src/mod_muc.erl
parentValidate module options on start_module/2 (diff)
Introduce 'iqdisc' global option
Diffstat (limited to 'src/mod_muc.erl')
-rw-r--r--src/mod_muc.erl6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mod_muc.erl b/src/mod_muc.erl
index b37f1c94..56616b92 100644
--- a/src/mod_muc.erl
+++ b/src/mod_muc.erl
@@ -224,7 +224,7 @@ get_online_rooms_by_user(ServerHost, LUser, LServer) ->
init([Host, Opts]) ->
process_flag(trap_exit, true),
- IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue),
+ IQDisc = gen_mod:get_opt(iqdisc, Opts, gen_iq_handler:iqdisc(Host)),
#state{access = Access, host = MyHost,
history_size = HistorySize, queue_type = QueueType,
room_shaper = RoomShaper} = State = init_state(Host, Opts),
@@ -259,8 +259,8 @@ handle_call({create, Room, From, Nick, Opts}, _From,
{reply, ok, State}.
handle_cast({reload, ServerHost, NewOpts, OldOpts}, #state{host = OldHost}) ->
- NewIQDisc = gen_mod:get_opt(iqdisc, NewOpts, one_queue),
- OldIQDisc = gen_mod:get_opt(iqdisc, OldOpts, one_queue),
+ NewIQDisc = gen_mod:get_opt(iqdisc, NewOpts, gen_iq_handler:iqdisc(ServerHost)),
+ OldIQDisc = gen_mod:get_opt(iqdisc, OldOpts, gen_iq_handler:iqdisc(ServerHost)),
NewMod = gen_mod:db_mod(ServerHost, NewOpts, ?MODULE),
NewRMod = gen_mod:ram_db_mod(ServerHost, NewOpts, ?MODULE),
OldMod = gen_mod:db_mod(ServerHost, OldOpts, ?MODULE),