Stub Basic_qos

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"