fix publisher

tuntron · Jul 29, 2018 · 64e4c2a · 64e4c2a
1 parent 158350c
commit 64e4c2a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/client/main.go b/client/main.go
@@ -120,7 +120,7 @@ func main() {
 	service := micro.NewService()
 	service.Init()
 
-	p := micro.NewPublisher("example", service.Client())
+	p := micro.NewPublisher("topic.example", service.Client())
 
 	fmt.Println("\n--- Publisher example ---")
 	pub(p)

diff --git a/server/main.go b/server/main.go
@@ -28,7 +28,7 @@ func main() {
 	// Register Subscribers
 	if err := server.Subscribe(
 		server.NewSubscriber(
-			"topic.go.micro.srv.example",
+			"topic.example",
 			new(subscriber.Example),
 		),
 	); err != nil {
@@ -37,7 +37,7 @@ func main() {
 
 	if err := server.Subscribe(
 		server.NewSubscriber(
-			"topic.go.micro.srv.example",
+			"topic.example",
 			subscriber.Handler,
 		),
 	); err != nil {