diff --git a/amqp_relay.ml b/amqp_relay.ml index 77cc98f..d5adbd7 100644 --- a/amqp_relay.ml +++ b/amqp_relay.ml @@ -355,6 +355,9 @@ let handle_method conn channel m = | false -> send_warning conn not_found (pseudotype^" '"^sink^"' not found")) | Basic_ack (delivery_tag, multiple) -> return () + | Basic_qos (_, _, _) -> + ignore (Log.warn "Ignoring Basic_qos instruction from client" []); + send_method conn channel Basic_qos_ok | _ -> let (cid, mid) = method_index m in die not_implemented (Printf.sprintf "Unsupported method (or method arguments) %s"