summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBen Hood <0x6e6562@gmail.com>2008-12-07 01:34:42 +0000
committerBen Hood <0x6e6562@gmail.com>2008-12-07 01:34:42 +0000
commit9be5280cefca99ceebcedc6bc071efd96911b292 (patch)
tree9a36db68e965cb9ea272424d1aa07126d555b4c8
parent5477c63fa7ef208bab3589b5786c2868580bbf30 (diff)
downloadrabbitmq-server-git-9be5280cefca99ceebcedc6bc071efd96911b292.tar.gz
Added match for setting the global flag
-rw-r--r--src/rabbit_channel.erl4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 240ee3d3b2..55617abbe8 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -424,6 +424,10 @@ handle_method(#'basic.cancel'{consumer_tag = ConsumerTag,
end
end;
+handle_method(#'basic.qos'{global = true}, _, _State) ->
+ rabbit_misc:protocol_error(not_implemented,
+ "Global flag for basic.qos not implementented");
+
handle_method(#'basic.qos'{prefetch_count = PrefetchCount},
_, State = #ch{limiter = Limiter}) ->
rabbit_limiter:set_prefetch_count(Limiter, PrefetchCount),