The current implementation waits for a "success" message. In some cases, it's useful to check for a "failure" message and stop waiting. Change this class to support that.