Finished implementation for reactive message client