#use "topfind";;
#require "netamqp";;

open Netamqp_types
open Printf

let () =
  Netamqp_endpoint.Debug.enable := true;
  Netamqp_transport.Debug.enable := true


let esys = Unixqueue.create_unix_event_system()
let p = `TCP(`Inet("localhost", Netamqp_endpoint.default_port))
let ep = Netamqp_endpoint.create p (`AMQP_0_9 `One) esys
let c = Netamqp_connection.create ep
let auth = Netamqp_connection.plain_auth "guest" "guest"

let test1() =
  Netamqp_connection.open_s c [ auth ] (`Pref "en") "/";
  eprintf "*** Connection could be opened, and the proto handshake is done!\n%!";
  Netamqp_connection.close_s c;
  eprintf "*** Connection could be closed!\n%!"

let test2() =
  Netamqp_connection.open_s c [ auth ] (`Pref "en") "/";
  eprintf "*** Connection could be opened, and the proto handshake is done!\n%!";
  let co = Netamqp_channel.open_s c 1 in
  eprintf "*** Channel could be opened!\n%!";
  co

let test3 co =
  Netamqp_channel.close_s co;
  eprintf "*** Channel could be closed!\n%!";
  Netamqp_connection.close_s c;
  eprintf "*** Connection could be closed!\n%!"