dart_amqp

dart_amqp copied to clipboard

I want to bind a fanout exchange to a direct exchange.

RasoulPiramoon

lkrjangid1

Shouldn't it be dart_amqp?

p3et-jambit

Can i listen a topic with this plugin?

3

I want listen a topic from my app. Can i do that?

barangungor

Any plans to implement heartbeats?

1

Are you guys having any plans to implement heartbeats? This is pretty necessary while we keep having lots of zombie connections on the server side!

cbalmeida

```dart // test.dart var client = new amqp.Client(settings: amqp.ConnectionSettings( host : 'localhost', port : 5672, maxConnectionAttempts: 99999, // -- "infinite" retries because setting this to 0 or -1 isn't supported...

bobjackman

Hi! RabbitMQ requires separate "qos" settings for each new consumer. (global = false) https://www.rabbitmq.com/consumer-prefetch.html#overview The abstract class "Channel" in the "qos" function is missing the "global" parameter. This will fix...

alexanderkind

web pltform

12

hello,i was trying this package on mobile platforms (android /ios) and it's work fine. but what about web. I think add web support it's will be a big contribution

mohammadshrahi

feat: implement heartbeat

1

Implements #35

xor22h

Expose client socket to handle errors

2

Hi, Is it possible to expose the socket in ClientImpl to handle errors? At present, if the client disconnects after establishing a connection, there is no way of knowing. If...

scottk