formatting and subscriber cleanup
add ability to ack and reject messages
fix threading issue