Re: [Caml-list] [ANN] ocaml-amqp 0.0.1

[Anders Peter Fugmann <anders@fugmann.net>]

On 12/11/15 22:37, Marek Kubica wrote:
> Hello,
>
> On Sat, 7 Nov 2015 19:45:10 +0100
> Anders Peter Fugmann <anders@fugmann.net> 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