diff --git a/broker/default.go b/broker/default.go index 3f45c3ef..29dc1583 100644 --- a/broker/default.go +++ b/broker/default.go @@ -402,7 +402,7 @@ func (n *natsBroker) Subscribe(topic string, handler Handler, opts ...SubscribeO } func (n *natsBroker) String() string { - return "nats" + return "nats-e" } func (n *natsBroker) setOption(opts ...Option) {