Add initial contract for message bus

Ya observables!!