Losing Data? Async specific?

Yes, but the example code doesn't allow retry (nor does your blocking example), because the message was already consumed by passing it as an argument to the send() function. Of course the send() function could be changed to accept an immutable reference instead, but then that makes the code using the function more complex because it must ensure that the message gets dropped in the correct situations.