A brokered queue with acking and replay