Achilleas Anagnostopoulos

Results 19 comments of Achilleas Anagnostopoulos

FYI, the 0.2.2 release includes this change.

As mentioned above, supporting websockets requires to implement the STOMP protocol which is fundamentally different than the AMQP binary protocol that this client implements. However, it might be possible to...

Hi there! If you check the [documentation](https://github.com/achilleasa/dart_amqp/blob/019d59aff5ac19d5b03c7dcb780429b03c9034c9/lib/src/client/channel.dart#L23) for `queue()` it states that you can just set `declare: false` specifically for this use-case. If that doesn't work as expected then you...

At the moment the driver only supports round-robin load-balancing. However, it shouldn't be too hard to refactor the code and implement different load-balancing policies if more people request this. Are...

Sorry for the late reply. Implementing this will probably require refactoring the driver to support pluggable connection selection policies (currently the driver does a simple RR on the healthy connection...

It sounds like you want to configure a per-consumer pre-fetch count of 5. You can start with the receiver example [here](https://github.com/achilleasa/dart_amqp/blob/master/example/hello/receive.dart) and specify an appropriate [QoS](https://github.com/achilleasa/dart_amqp/blob/master/lib/src/client/channel.dart#L56-L58)) for your use case....

This behavior is intentional as per the comment about not re-establishing topologies after re-connecting. The client will surface connection lost errors via a broadcast stream that you can subscribe to....

Hi there. The driver should work as expected (no issues reported so far) but the is no scheduled work for adding new features at the moment. Are you interested in...

You can find a minimal example of streaming query results in the API docs: https://github.com/achilleasa/dart_cassandra_cql/blob/master/API.md#streaming-query-results