Commit Graph

10 Commits

Author SHA1 Message Date
0baea58938 wait nats drain since it's asynchronous
1. nats subscription draining is removed, since it is asynchronous,
   and there is no reliable way to detect when it is finished.
   Remove this option to avoid confusion.
2. nats connection draining is kept, and use 2 callbacks to detect
   draining timeout (timeout is set via `nats.Options`) or finish.
3. Also honour options passed in `broker.Init()` (previously only
   `broker.New()` is honoured).
2019-08-07 17:58:45 +08:00
a29ce20e31 Changed default NATS address to nats://127.0.0.1:4222 in nats test 2019-06-06 12:06:14 +01:00
ca769444e7 set localhost for nats 2019-05-31 13:18:22 +01:00
1200386097 Add nats broker as a default 2019-05-29 16:46:57 +01:00
04e07f4b39 Move plugins to go-plugins 2015-11-25 00:17:15 +00:00
5d88115f2a update links from myodc to micro 2015-11-20 16:17:33 +00:00
b91af916f9 Add pub/sub to client/server and make broker more low level 2015-06-12 19:52:27 +01:00
36b5ca46fe Change initialisation and add metadata 2015-05-26 22:39:48 +01:00
32928bfb67 Publish/Subscribe with context 2015-05-23 23:16:26 +01:00
74fd1fc989 Restructure go-micro layout and plugins 2015-05-23 20:04:16 +01:00