diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-06-22 17:25:49 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-06-22 17:25:49 +0100 |
| commit | 3cadfbd5c0fc45e390a414829bcf4ac388810cd8 (patch) | |
| tree | a663658b4cb7f182b1b51493b435fb209c118850 | |
| parent | 85f08fff3bc069fd4357e9b26da4aae0b4493d29 (diff) | |
| download | rabbitmq-server-git-3cadfbd5c0fc45e390a414829bcf4ac388810cd8.tar.gz | |
whoops, missed off a priority pcast.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 05a32a093c..4858a984ae 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -229,7 +229,7 @@ set_mode(VHostPath, Queue, ModeBin) when is_binary(VHostPath) andalso is_binary(Queue) -> Mode = list_to_atom(binary_to_list(ModeBin)), with(rabbit_misc:r(VHostPath, queue, Queue), - fun(Q) -> gen_server2:cast(Q #amqqueue.pid, {set_mode, Mode}) end). + fun(Q) -> gen_server2:pcast(Q #amqqueue.pid, 10, {set_mode, Mode}) end). info(#amqqueue{ pid = QPid }) -> gen_server2:pcall(QPid, 9, info, infinity). |