dart_amqp

dart_amqp copied to clipboard

Client timeout handling

1

Hi, Any example of handling the client timeout?? and also can we set the timeout length manually?? Thanks.

jeremy1265

auto-delete for exchanges

3

there isn't an option to set the auto-delete flags for exchange. I was digging the source and you kinda use some source generator, right? Can you explain a little bit...

jodinathan

After a weekend without traffic on a rabbitmq connection the first publication leads to the following message in rabbitmq logs: ``` =INFO REPORT==== 22-Mar-2019::08:04:05 === connection (10.233.77.108:54878 -> 10.233.81.213:5672): user...

a14n

heartbeat support

2

In `dart_amqp-0.1.1` I can see a `TuningSettings.heartbeatPeriod` but this property doesn't seem to be used. Is it supposed to work?

a14n

publish message without queue or exchange declaration

1

*This implementation is dirty and needs to be worked on (I would be happy if someone raise a hand)* If you grant write but not configuration access to your application...

Jafarili

Sharing connection across isolates

1

Hello. I'm building an app which allows a core device exchanging messages to several children devices at the same time. So what I have built is a set up of...

thanh-cao

HELP: executing messages only one time

2

i want to perform a simple task run consumer in background for a queue, and pick 5 messages at a time and perform operation on each. how to achieve this?

moinologics

Hi, As, _"the driver does not currently support recovering client topologies when re-establishing connections"_, Could it be possible to add an example demonstrating how to do this properly ? There...

nicolascrochet7

amqp connection lost, and recreate multiples consumers in same queue

1

I have been used this lib, but after a while the connection auto close and when start it again it connect with another consumer in queue, I can publish in...

fabios1010

Some services provide feature like AMQP over WebSockets that uses inside AMQP WebSocket TCP relay. For this cases replacing dart:io imports by universal:io, implementing uint64 converter (flutter web doesn't support...

AlxSidenko