message.Message.Ack
andmessage.Message.Nack
now returnbool
instead oferror
message.Subscriber.Subscribe
now acceptscontext.Context
as the first argumentmessage.Subscriber.Subscribe
now returns<-chan *Message
instead ofchan *Message
message.Router.AddHandler
andmessage.Router.AddNoPublisherHandler
now panic, instead of returning error
- updated all Pub/Subs to new
message.Subscriber
interface gochannel.NewGoChannel
now acceptsgochannel.Config
, instead of positional parametershttp.NewSubscriber
now acceptshttp.SubscriberConfig
, instead of positional parameters
metrics.NewMetrics
is removed, please use the metrics component instead
watermill.LoggerAdapter
interface now requires aWith(fields LogFields) LoggerAdapter
method