update broker

broker/default.go

@@ -12,8 +12,8 @@ import (
 
 	"github.com/micro/go-micro/codec/json"
 	"github.com/micro/go-micro/registry"
-	"github.com/micro/go-micro/util/log"
 	"github.com/micro/go-micro/util/addr"
+	"github.com/micro/go-micro/util/log"
 	"github.com/nats-io/nats-server/v2/server"
 	nats "github.com/nats-io/nats.go"
 )

broker/http/http.go

@@ -20,6 +20,7 @@ import (
 	"github.com/google/uuid"
 	"github.com/micro/go-micro/broker"
 	"github.com/micro/go-micro/codec/json"
+	"github.com/micro/go-micro/config/cmd"
 	merr "github.com/micro/go-micro/errors"
 	"github.com/micro/go-micro/registry"
 	"github.com/micro/go-micro/registry/cache"
@@ -29,6 +30,10 @@ import (
 	"golang.org/x/net/http2"
 )
 
+func init() {
+	cmd.DefaultBrokers["http"] = NewBroker
+}
+
 // HTTP Broker is a point to point async broker
 type httpBroker struct {
 	id      string