Adding a new Rx BusNotifications API

The first cab of the rank is to expose error streams:
- MessageHasFailedAFirstLevelRetryAttempt
- MessageHasBeenSentToSecondLevelRetries
- MessageSentToErrorQueue
two things come to mind. a reader writer lock. and clone the list in the thread safe code so u dont need to do the  OnNext inside the lock.