From 1cbe06413eebe2d206724be636bfc52a9b85a1ca Mon Sep 17 00:00:00 2001
From: Asim <asim@chuhnk.me>
Date: Tue, 26 Jan 2016 01:07:18 +0000
Subject: [PATCH] Moving mercury example to plugins

---
 examples/mercury/README.md                |  7 -----
 examples/mercury/mercury/client/client.go | 30 ------------------
 examples/mercury/mercury/server/server.go | 34 --------------------
 examples/mercury/micro/client/client.go   | 37 ----------------------
 examples/mercury/micro/server/server.go   | 38 -----------------------
 5 files changed, 146 deletions(-)
 delete mode 100644 examples/mercury/README.md
 delete mode 100644 examples/mercury/mercury/client/client.go
 delete mode 100644 examples/mercury/mercury/server/server.go
 delete mode 100644 examples/mercury/micro/client/client.go
 delete mode 100644 examples/mercury/micro/server/server.go

diff --git a/examples/mercury/README.md b/examples/mercury/README.md
deleted file mode 100644
index bc866fc5..00000000
--- a/examples/mercury/README.md
+++ /dev/null
@@ -1,7 +0,0 @@
-# Mercury
-
-An **experimental** integration for [mondo/mercury](https://github.com/mondough/mercury)
-
-mercury/{client,server} are standard mercury implementations for compatibility testing sake.
-
-micro/{client,server} are micro implementations of mercury's request/response system.
diff --git a/examples/mercury/mercury/client/client.go b/examples/mercury/mercury/client/client.go
deleted file mode 100644
index cacbf704..00000000
--- a/examples/mercury/mercury/client/client.go
+++ /dev/null
@@ -1,30 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"time"
-
-	hello "github.com/micro/micro/examples/greeter/server/proto/hello"
-	"github.com/mondough/mercury"
-	tmsg "github.com/mondough/typhon/message"
-	"github.com/mondough/typhon/rabbit"
-)
-
-func main() {
-	req := mercury.NewRequest()
-	req.SetService("foo")
-	req.SetEndpoint("Say.Hello")
-	req.SetBody(&hello.Request{
-		Name: "John",
-	})
-	tmsg.ProtoMarshaler().MarshalBody(req)
-	trans := rabbit.NewTransport()
-	rsp, err := trans.Send(req, time.Second)
-	if err != nil {
-		fmt.Println(err)
-		return
-	}
-	tmsg.ProtoUnmarshaler(new(hello.Response)).UnmarshalPayload(rsp)
-
-	fmt.Println(rsp.Body())
-}
diff --git a/examples/mercury/mercury/server/server.go b/examples/mercury/mercury/server/server.go
deleted file mode 100644
index ef1236af..00000000
--- a/examples/mercury/mercury/server/server.go
+++ /dev/null
@@ -1,34 +0,0 @@
-package main
-
-import (
-	"github.com/mondough/mercury"
-	"github.com/mondough/mercury/server"
-	"github.com/mondough/mercury/service"
-	"github.com/mondough/typhon/rabbit"
-
-	hello "github.com/micro/micro/examples/greeter/server/proto/hello"
-)
-
-func handler(req mercury.Request) (mercury.Response, error) {
-	request := req.Body().(*hello.Request)
-	rsp := req.Response(&hello.Response{
-		Msg: "Hey " + request.Name,
-	})
-	return rsp, nil
-}
-
-func main() {
-	s := service.Init(service.Config{
-		Name:      "foo",
-		Transport: rabbit.NewTransport(),
-	})
-
-	s.Server().AddEndpoints(server.Endpoint{
-		Name:     "Say.Hello",
-		Handler:  handler,
-		Request:  new(hello.Request),
-		Response: new(hello.Response),
-	})
-
-	s.Run()
-}
diff --git a/examples/mercury/micro/client/client.go b/examples/mercury/micro/client/client.go
deleted file mode 100644
index 21e48f79..00000000
--- a/examples/mercury/micro/client/client.go
+++ /dev/null
@@ -1,37 +0,0 @@
-package main
-
-import (
-	"fmt"
-
-	"github.com/micro/go-micro/client"
-	mcodec "github.com/micro/go-plugins/codec/mercury"
-	"github.com/micro/go-plugins/selector/mercury"
-	"github.com/micro/go-plugins/transport/rabbitmq"
-	hello "github.com/micro/micro/examples/greeter/server/proto/hello"
-
-	"golang.org/x/net/context"
-)
-
-func main() {
-	rabbitmq.DefaultExchange = "b2a"
-	rabbitmq.DefaultRabbitURL = "amqp://localhost:5672"
-
-	c := client.NewClient(
-		client.Selector(mercury.NewSelector()),
-		client.Transport(rabbitmq.NewTransport([]string{})),
-		client.Codec("application/x-protobuf", mcodec.NewCodec),
-		client.ContentType("application/x-protobuf"),
-	)
-
-	req := c.NewRequest("foo", "Say.Hello", &hello.Request{
-		Name: "John",
-	})
-
-	rsp := &hello.Response{}
-
-	if err := c.Call(context.Background(), req, rsp); err != nil {
-		fmt.Println(err)
-	}
-
-	fmt.Println(rsp)
-}
diff --git a/examples/mercury/micro/server/server.go b/examples/mercury/micro/server/server.go
deleted file mode 100644
index 0d3112f4..00000000
--- a/examples/mercury/micro/server/server.go
+++ /dev/null
@@ -1,38 +0,0 @@
-package main
-
-import (
-	"flag"
-	"github.com/micro/go-micro/server"
-	mcodec "github.com/micro/go-plugins/codec/mercury"
-	"github.com/micro/go-plugins/transport/rabbitmq"
-	hello "github.com/micro/micro/examples/greeter/server/proto/hello"
-
-	"golang.org/x/net/context"
-)
-
-type Say struct{}
-
-func (s *Say) Hello(ctx context.Context, req *hello.Request, rsp *hello.Response) error {
-	rsp.Msg = "Hey " + req.Name
-	return nil
-}
-
-func main() {
-	flag.Parse()
-	rabbitmq.DefaultExchange = "b2a"
-	rabbitmq.DefaultRabbitURL = "amqp://localhost:5672"
-
-	s := server.NewServer(
-		server.Name("foo"),
-		server.Id("foo"),
-		server.Address("foo"),
-		server.Transport(rabbitmq.NewTransport([]string{})),
-		server.Codec("application/x-protobuf", mcodec.NewCodec),
-	)
-	s.Handle(
-		s.NewHandler(&Say{}),
-	)
-
-	s.Start()
-	select {}
-}