Robert Laszczak
Robert Laszczak
Hello, I will be happy to merge any changes that are working and not affecting current functionality and flexibility :) Feel free to experiment, with current tests It should be...
Metadata are strings because almost all of Pub/Subs are supporting only simple types for metadata. So the main thing that we need to keep is to make `amqp.Marshaler` transparent, so...
> But nevertheless watermill shouldn't fail on standard headers ;) Yup, it is not so good :) I have couple ideas how it can be fixed, but nothing sounds good:...
We will look on that :) Do you think that may be integrated as a component? Or closer to Pub/Sub?
@iwyg I had no time to dig into it to be honest :) If you have some knowledge about EventStore and you can provide some ideas/guidelines it may be helpful...
Sure :) If you need help we can do a call and I can share what I already know.
Do you have more details? Do you mean that this flow of reconnecting is not executing properly: https://github.com/ThreeDotsLabs/watermill-amqp/blob/master/pkg/amqp/subscriber.go#L70 ?
Hello @sdeancos @duolabmeng6 I checked locally and with tests (https://github.com/ThreeDotsLabs/watermill-amqp/blob/master/pkg/amqp/pubsub_reconnect_test.go) and it seems that reconnect is working for me properly. Can you provide a bit more details to reproduce it?...
Hello, Publish is implemented without Channel reusing to ensure that all messages are sent after Publish was executed (so in other words if your service will die you are sure...