diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-12-07 01:40:09 +0000 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-12-07 01:40:09 +0000 |
| commit | da04837ed0fd68aa54a92d0e1e8e38905cb468db (patch) | |
| tree | 3933a71d965081b296a8beaa56d8f9ac4a700dd7 | |
| parent | 9be5280cefca99ceebcedc6bc071efd96911b292 (diff) | |
| download | rabbitmq-server-git-da04837ed0fd68aa54a92d0e1e8e38905cb468db.tar.gz | |
Added catch for pre-fetch size
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 55617abbe8..a8db5b3f64 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -428,6 +428,11 @@ 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_size = Size}, + _, _State) when Size /= 0 -> + rabbit_misc:protocol_error(not_implemented, + "Pre-fetch size for basic.qos not implementented"); + handle_method(#'basic.qos'{prefetch_count = PrefetchCount}, _, State = #ch{limiter = Limiter}) -> rabbit_limiter:set_prefetch_count(Limiter, PrefetchCount), |