update to latest micro

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2022-06-27 00:41:18 +03:00
parent fd8c454bae
commit 7d649e8156
3 changed files with 35 additions and 13 deletions

View File

@@ -109,10 +109,6 @@ func (h *httpServer) Init(opts ...server.Option) error {
h.RUnlock()
return err
}
if err := h.opts.Auth.Init(); err != nil {
h.RUnlock()
return err
}
if err := h.opts.Logger.Init(); err != nil {
h.RUnlock()
return err
@@ -345,6 +341,7 @@ func (h *httpServer) Register() error {
}
opts = append(opts, broker.SubscribeContext(subCtx))
opts = append(opts, broker.SubscribeAutoAck(sb.Options().AutoAck))
opts = append(opts, broker.SubscribeBodyOnly(sb.Options().BodyOnly))
sub, err := config.Broker.Subscribe(subCtx, sb.Topic(), handler, opts...)
if err != nil {