From 72d8dc89fbc4be633a1f4194a812ca8275efbc54 Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Tue, 4 Dec 2018 17:22:20 +0000
Subject: [PATCH] add cmd and bug fix

---
 cmd/cmd.go                | 2 ++
 registry/gossip/gossip.go | 8 ++++++--
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/cmd/cmd.go b/cmd/cmd.go
index 2ed2954a..4f23743d 100644
--- a/cmd/cmd.go
+++ b/cmd/cmd.go
@@ -20,6 +20,7 @@ import (
 	// registries
 	"github.com/micro/go-micro/registry"
 	"github.com/micro/go-micro/registry/consul"
+	"github.com/micro/go-micro/registry/gossip"
 	"github.com/micro/go-micro/registry/mdns"
 
 	// selectors
@@ -171,6 +172,7 @@ var (
 
 	DefaultRegistries = map[string]func(...registry.Option) registry.Registry{
 		"consul": consul.NewRegistry,
+		"gossip": gossip.NewRegistry,
 		"mdns":   mdns.NewRegistry,
 	}
 
diff --git a/registry/gossip/gossip.go b/registry/gossip/gossip.go
index 4e35d873..27240416 100644
--- a/registry/gossip/gossip.go
+++ b/registry/gossip/gossip.go
@@ -28,7 +28,8 @@ type gossipRegistry struct {
 }
 
 var (
-	defaultPort = 8118
+	// defaults to random port
+	defaultPort = 0
 )
 
 type broadcast struct {
@@ -349,6 +350,7 @@ func (g *gossipRegistry) run() error {
 		RetransmitMult: 3,
 	}
 
+	g.queue = d.queue
 	g.memberlist = m
 	g.delegate = d
 	d.registry = g
@@ -364,12 +366,14 @@ func NewRegistry(opts ...registry.Option) registry.Registry {
 	}
 
 	g := &gossipRegistry{
-		opts: options,
+		opts:     options,
+		services: make(map[string][]*registry.Service),
 	}
 	if err := g.run(); err != nil {
 		log.Fatal(err)
 	}
 
+	log.Logf("Registry gossiping at %s", g.memberlist.LocalNode().Address())
 	// return gossip registry
 	return g
 }