From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Original-To: caml-list@sympa.inria.fr Delivered-To: caml-list@sympa.inria.fr Received: from mail3-relais-sop.national.inria.fr (mail3-relais-sop.national.inria.fr [192.134.164.104]) by sympa.inria.fr (Postfix) with ESMTPS id C5F327EEFA for ; Thu, 12 Nov 2015 23:33:19 +0100 (CET) IronPort-PHdr: 9a23:6LWHNhKS3m5hlbbxi9mcpTZWNBhigK39O0sv0rFitYgUIvjxwZ3uMQTl6Ol3ixeRBMOAu68C1rKd6/qocFdDyKjCmUhKSIZLWR4BhJdetC0bK+nBN3fGKuX3ZTcxBsVIWQwt1Xi6NU9IBJS2PAWK8TWM5DIfUi/yKRBybrysXNWC0oLqj6vqodX6WEZhunmUWftKNhK4rAHc5IE9oLBJDeIP8CbPuWZCYO9MxGlldhq5lhf44dqsrtY4q3wD89pozcNLUL37cqIkVvQYSW1+ayFmrPHs4DzKVwaMrlgBWGQdm1IcBgHf4RLSTpbvsy/7pONh2S6ce8v7UeZndy6l6vJCThPlkjxPDzMl/XufpNF/iatdplr1rhpzzpTPSI+IO/93eKWbe94GEzkSFv1NXjBMV9vvJ7AECPAMaKMB99Hw Authentication-Results: mail3-smtp-sop.national.inria.fr; spf=None smtp.pra=anders@fugmann.net; spf=Pass smtp.mailfrom=anders@fugmann.net; spf=None smtp.helo=postmaster@gw.fugmann.net Received-SPF: None (mail3-smtp-sop.national.inria.fr: no sender authenticity information available from domain of anders@fugmann.net) identity=pra; client-ip=90.184.182.235; receiver=mail3-smtp-sop.national.inria.fr; envelope-from="anders@fugmann.net"; x-sender="anders@fugmann.net"; x-conformance=sidf_compatible Received-SPF: Pass (mail3-smtp-sop.national.inria.fr: domain of anders@fugmann.net designates 90.184.182.235 as permitted sender) identity=mailfrom; client-ip=90.184.182.235; receiver=mail3-smtp-sop.national.inria.fr; envelope-from="anders@fugmann.net"; x-sender="anders@fugmann.net"; x-conformance=sidf_compatible; x-record-type="v=spf1" Received-SPF: None (mail3-smtp-sop.national.inria.fr: no sender authenticity information available from domain of postmaster@gw.fugmann.net) identity=helo; client-ip=90.184.182.235; receiver=mail3-smtp-sop.national.inria.fr; envelope-from="anders@fugmann.net"; x-sender="postmaster@gw.fugmann.net"; x-conformance=sidf_compatible X-IronPort-Anti-Spam-Filtered: true X-IronPort-Anti-Spam-Result: A0AOBQCQEkVW/+u2uFpegw8sU2++TIFlIYVvAoE/ORMBAQEBAQEBAYEJgi2CBwEBAQMBIxUIAQE2AQEPCxgCAgUWCwICCQMCAQIBRQYNBgICiCIJAwmyKnGEYwEFi3UBAQEHAgEaBoEBilGEQjGDAoFElk2FHYllSYN3liojAj6CBIIBcYNzBoFEAQEB X-IPAS-Result: A0AOBQCQEkVW/+u2uFpegw8sU2++TIFlIYVvAoE/ORMBAQEBAQEBAYEJgi2CBwEBAQMBIxUIAQE2AQEPCxgCAgUWCwICCQMCAQIBRQYNBgICiCIJAwmyKnGEYwEFi3UBAQEHAgEaBoEBilGEQjGDAoFElk2FHYllSYN3liojAj6CBIIBcYNzBoFEAQEB X-IronPort-AV: E=Sophos;i="5.20,284,1444687200"; d="scan'208";a="153647028" Received: from gw.fugmann.net ([90.184.182.235]) by mail3-smtp-sop.national.inria.fr with ESMTP/TLS/ADH-AES256-GCM-SHA384; 12 Nov 2015 23:33:18 +0100 Received: from [IPv6:2001:470:dc46:1:daa2:5eff:fe95:453e] (zaphod.fugmann.net [IPv6:2001:470:dc46:1:daa2:5eff:fe95:453e]) (using TLSv1.2 with cipher ECDHE-RSA-AES128-GCM-SHA256 (128/128 bits)) (No client certificate requested) by gw.fugmann.net (Postfix) with ESMTPSA id 9A5032E7C0D6; Thu, 12 Nov 2015 23:33:16 +0100 (CET) DKIM-Signature: v=1; a=rsa-sha256; c=simple/simple; d=fugmann.net; s=mail; t=1447367596; bh=bCBZ37HpIc6MGCQrd1QKagC3lPYwGsSVde3drgNo4Qw=; h=Subject:To:References:Cc:From:Date:In-Reply-To:From; b=gDcSpRSTvBfCEw1sqO2tOH1cUqiNv56FQoNfIs4mpdbn/9PCUP4+4pt8K+i2b9/n6 kf3KT6wYII37BQ3Yn7VoGSWuPvcVj+Rc1nz2GmkjKbzHEvunUL6jKNVv32WKd7y6JZ rj5xwnxI7WaAD7lsc29ZEkMQDT7gOlUbt7UJ0zp8= To: Marek Kubica References: <5635C7E3.80207@fugmann.net> <20151107153222.71ff0157@xivilization.net> <563E46B6.8070607@fugmann.net> <20151112223753.0f8b7145@xivilization.net> Cc: caml-list From: Anders Peter Fugmann Message-ID: <564513A7.1040805@fugmann.net> Date: Thu, 12 Nov 2015 23:33:11 +0100 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:38.0) Gecko/20100101 Icedove/38.3.0 MIME-Version: 1.0 In-Reply-To: <20151112223753.0f8b7145@xivilization.net> Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 7bit Subject: Re: [Caml-list] [ANN] ocaml-amqp 0.0.1 On 12/11/15 22:37, Marek Kubica wrote: > Hello, > > On Sat, 7 Nov 2015 19:45:10 +0100 > Anders Peter Fugmann wrote: > >> Please let me know how it works out. > > I tried it and it seems to be working quite well. Very nice. Sending a > message based on the tests/main.ml works just fine, receiving it with > pika was no problem, similarly receiving with Langohr worked just as > well. Glad to hear that. Btw, which amqp-server have you tested against? > > My biggest problem has, in fact been Async itself. As I tried to send a > single message via AMQP and then terminate the program I added the > Queue.publish call and then >>='d in a function which calls Async's > Shutdown. Unfortunately this terminates the Scheduler before it has a > chance to send the message. Need to explore more of Async to figure out > how to wait for the Deferred.t to be realized before shutting down. Async is not to blame here. The answer should have been 'just close the channel / connection to make sure all queues are flushed', but it seems I forgot to implement it. I will try and implement it this weekend, along with per message and per queue flushing. In the meantime, if you are using rabbitmq then you can enable confirms when creating the channel. Publishing will then return only when rabbitmq has acknowledged the message. > >> Please be aware that even though I do not expect major changes to the >> API, the library is still in heavy development. Please send feedback, >> including suggestions on the API so that these can be incorporated >> into the next version. > > So far I haven't had issues with the API. But having some searchable > docs published somewhere would definitely be helpful. I don't know how to make is searchable, but ocamldoc generated documentation is available there: http://andersfugmann.github.io/ocaml-amqp/ > > regards, > Marek > /Anders