You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Please fix the formatting off your code. It's unreadable. You are using an etcd registry and rabbitmq. Both publisher and consumer will need to be using the same configuration.
fail to publish mq, with the "service not found".
can anyone help ? thank you.
package main
import (
"context"
"fmt"
mq "github.com/go-micro/plugins/v4/broker/rabbitmq"
"github.com/go-micro/plugins/v4/registry/etcd"
"log"
"time"
)
var (
topic = "go.micro.topic.foo"
)
type Request struct {
Name string
json:"name"
}
type Response struct {
Message string
json:"message"
}
type Helloworld struct{}
func (h *Helloworld) Greeting(ctx context.Context, req *Request, rsp *Response) error {
rsp.Message = "Hello " + req.Name
fmt.Println("!!!!!!!!!!!!!")
}
func main() {
}
The text was updated successfully, but these errors were encountered: