12 Commits

Author	SHA1	Message	Date
Asim Aslam	1d311ab457	Embedded NATS Broker (#1110) ... * if the address is produced by a default route don't hash it * embedded nats * fix url parsing * don't override help * add ready flag	2020-01-14 13:23:16 +00:00
Vasiliy Tolstov	a1eaf9cc20	linting fixes ... Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2019-12-04 00:22:02 +03:00
magodo	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
Milos Gajdos	a29ce20e31	Changed default NATS address to nats://127.0.0.1:4222 in nats test	2019-06-06 12:06:14 +01:00
Asim Aslam	ca769444e7	set localhost for nats	2019-05-31 13:18:22 +01:00
Asim Aslam	1200386097	Add nats broker as a default	2019-05-29 16:46:57 +01:00
Asim	04e07f4b39	Move plugins to go-plugins	2015-11-25 00:17:15 +00:00
Asim	5d88115f2a	update links from myodc to micro	2015-11-20 16:17:33 +00:00
Asim	b91af916f9	Add pub/sub to client/server and make broker more low level	2015-06-12 19:52:27 +01:00
Asim	36b5ca46fe	Change initialisation and add metadata	2015-05-26 22:39:48 +01:00
Asim	32928bfb67	Publish/Subscribe with context	2015-05-23 23:16:26 +01:00
Asim	74fd1fc989	Restructure go-micro layout and plugins	2015-05-23 20:04:16 +01:00