Closed shoothzj closed 2 years ago
allow bridgemq to cost the message
add bool return value on Publish method to allow bridge mq to cost the message
Publish
type BridgeMQ interface { Publish(e *Elements) (bool, error) }
If the bridgeMq returns true, we won't send msg to it's subscriber
@chowyu08 Please take a look, if you approve that, I am willing and happy to submit a PR
allow bridgemq to cost the message
suggest implementation
add bool return value on
Publishmethod to allow bridge mq to cost the messageIf the bridgeMq returns true, we won't send msg to it's subscriber
@chowyu08 Please take a look, if you approve that, I am willing and happy to submit a PR