Achilleas Anagnostopoulos

Take a look in the `example` folder. [This](https://github.com/achilleasa/dart_amqp/blob/master/example/pubsub/receive_logs.dart) example in particular demonstrates how to listen to a particular topic in a pubsub scenario.

In the linked example, the exchange will fan out a copy of each message to _each_ subscribed (private) queue. The main idea here is that each consumer defines a private...

Since this seems to be the most requested missing feature so far I will try to allocate some time over the next weeks to add support for heartbeats.

Apologies for the late reply. Can you elaborate more on your particular use-case? For web applications you would typically connect to amqp from your backend and use some sort of...

AFAICT the main issue (as you can see [here](https://pub.dev/packages/dart_amqp/score)) that prevents it from running on the web is the `dart:io` import. However, the [universal_io](https://pub.dev/packages/universal_io) package might be a drop-in replacement...

I am not 100% sure that this PR implements the [spec](https://www.rabbitmq.com/resources/specs/amqp0-9-1.pdf) correctly. In particular, only channel zero must respond to heartbeats; if you receive a heartbeat on another channel the...

When the client loses connection to the server, any _write_ attempt should fail with a socket error. I am not sure how the `onDone` callback for sockets is implemented internally...

Hi there. You are correct. The [generate_bindings](https://github.com/achilleasa/dart_amqp/blob/master/tool/generate_bindings.dart) tool basically reads the amqp specification from an XML document (available [here](https://www.rabbitmq.com/resources/specs/amqp0-9-1.xml)) and creates the bindings which are stored in the [bindings](https://github.com/achilleasa/dart_amqp/tree/master/lib/src/protocol/messages/bindings) folder....

At the moment the client is not supporting heartbeats so this value is forced to 0 during the initial [handshake](https://github.com/achilleasa/dart_amqp/blob/64b803d3694f75729fe72f180e6d096aa8227db2/lib/src/client/impl/channel_impl.dart#L130) with the server.

Regarding the above questions, you can find the spec for the upcoming 2.9 juju changes wrt. managing open ports across application endpoints [here](https://docs.google.com/document/d/1fb9UEWZRqiu7dTLW35jvtNHPaCXfVDKc3-jtA9XCViY/edit#). TLDR: we are adding support for `--endpoints`...